#apache-kafka
#apache-kafka
Вопрос:
У меня 3-узловой кластер kafka и 3-узловой кластер zookeeper. Каждая пара kafka и zookeeper запущена на одной виртуальной машине. Я обновил версию kafka с 0.10.2.2 до 2.1.1, через день она начинает выдавать нижеприведенные предупреждающие сообщения по всем темам. Обновление Kafka было выполнено поэтапно. Все разделы kafka имеют коэффициент репликации 2 и минимум.ISR 2. Может ли кто-нибудь помочь установить фактическую первопричину проблемы.
[2019-03-28 17:23:55.877 0000] WARN [Log partition=FirstTopic-6, dir=/apps/kafka/data] Found a corrupted index file corresponding to log file /apps/kafka/data/FirstTopic-6/00000000000000000494.log due to Corrupt time index found, time index file (/apps/kafka/data/FirstTopic-6/00000000000000000494.timeindex) has non-zero size but the last timestamp is 0 which is less than the first timestamp 1553720469480}, recovering segment and rebuilding index files... (kafka.log.Log)
[2019-03-28 17:23:55.877 0000] WARN [Log partition=NewTopic-3, dir=/apps/kafka/data] Found a corrupted index file corresponding to log file /apps/kafka/data/NewTopic-3/00000000000000000494.log due to Corrupt time index found, time index file (/apps/kafka/data/NewTopic-3/00000000000000000494.timeindex) has non-zero size but the last timestamp is 0 which is less than the first timestamp 1553720469480}, recovering segment and rebuilding index files... (kafka.log.Log)
[2019-03-28 17:23:55.877 0000] WARN [Log partition=SecondTopic-3, dir=/apps/kafka/data] Found a corrupted index file corresponding to log file /apps/kafka/data/SecondTopic-3/00000000000000000494.log due to Corrupt time index found, time index file (/apps/kafka/data/SecondTopic-3/00000000000000000494.timeindex) has non-zero size but the last timestamp is 0 which is less than the first timestamp 1553720469480}, recovering segment and rebuilding index files... (kafka.log.Log)
Комментарии:
1. Действительно ли это ошибка и о чем беспокоиться? Уровень предупреждения, и сообщение предполагает, что с ним разобрались. Заметили ли вы какие-либо другие проблемы с тем, как работает ваш кластер?
2. Привет, Марк, для меня это не блокировщик, но иногда kafka ведет себя странно. Я не уверен, что это виновник, но хотел бы знать фактическую первопричину проблемы.