KAFKA 1.0 - Неизвестная ошибка при получении данных для раздела темы - PullRequest
0 голосов
/ 25 апреля 2018

Получение ошибки ниже как потребитель к теме кафки. Издатель должен использовать сжатие gzip, а затем публиковать его в kafka из-за размера файла, превышающего 70 Мбайт без предыдущего gzip. Когда потребитель пытается прочитать кафку, появляется ошибка ниже. любые предложения?

10:56:26,082 [pool-13-thread-1] org.apache.kafka.clients.consumer.internals.Fetcher: Unknown error fetching data for topic-partition testKafka-0
WARN  2018-04-13 10:56:26,125 [pool-13-thread-1] org.apache.kafka.clients.consumer.internals.Fetcher: Unknown error fetching data for topic-partition testKafka-0

1 Ответ

0 голосов
/ 16 мая 2018

У меня была похожая проблема, я обнаружил, что версия kafka-client (потребительская) отличается от других. Пожалуйста, проверьте версию своего клиента и сделайте ее похожей / одинаковой везде. Пример: если вы используете клиентскую версию 0.11.0.0, тогда выполните перекрестную проверку, что это одинаково для всего проекта.

...