обновление зависимости kafka в camus вызывает сообщения, не прочитанные EtlRecordReader - PullRequest
0 голосов
/ 18 октября 2018

В моем проекте camus используется долгое время и никогда не обновляется.В проекте camus используется версия kafka 0.8.2.2.Я хочу найти обходной путь для использования kafka 1.0.0.

Поэтому я клонировал каталог и обновил зависимость.Когда я делаю это, Сообщение здесь требует дополнительных параметров здесь .

Как указано в ссылке на github выше, код компилируется, но сообщения не читаются из kafka из-за условия здесь .

Можно ли обновить зависимость kafka вместе с соответствующими конструкторами данных kafka.message.Message и заставить ее работать.

...