ошибка kafka: запрос смещения X, но у нас есть только сегменты журнала в диапазоне от Y до Z

У меня был рабочий экземпляр kafka, но теперь он выдает тысячи ошибок, которые выглядят так:

[2016-06-24 01:33:28,092] ОШИБКА [Диспетчер реплик на брокере 0]: ошибка при обработке запроса на выборку для раздела [test-topic,0] смещения 45 от потребителя с идентификатором корреляции 85452. Возможная причина: запрос смещения 45, но у нас есть только сегменты журнала в диапазоне от 0 до 0. (kafka.server.ReplicaManager)

Я использую конфигурацию по умолчанию. Я использую несколько тем в коде node.js.

UPD: мне помогает переустановка kafka, но хотелось бы знать первоисточник проблемы.


person Glen Swift    schedule 23.06.2016    source источник


Ответы (1)


Пожалуйста, прочтите здесь источник проблемы https://github.com/endgameinc/elasticsearch-river-kafka/issues/8

Возможно, вы удалили некоторые файлы или папки в kafka.

person rakeeee    schedule 20.09.2017