В моем проекте camus используется долгое время и никогда не обновляется.В проекте camus используется версия kafka 0.8.2.2.Я хочу найти обходной путь для использования kafka 1.0.0.
Поэтому я клонировал каталог и обновил зависимость.Когда я делаю это, Сообщение здесь требует дополнительных параметров здесь .
Как указано в ссылке на github выше, код компилируется, но сообщения не читаются из kafka из-за условия здесь .
Можно ли обновить зависимость kafka вместе с соответствующими конструкторами данных kafka.message.Message
и заставить ее работать.