Kafka v0.11.0.2
Kafka经纪人在PST时区运行了大约一个月，然后由于操作系统补丁，管理员将时区更改为EST，重启后，我们看到了消费者消息的重放（消费者偏移被重置为0） . 我们要求管理员将时区更改回PST，他们花了3天时间来更改它 . 在将时区更改回PST之后，在代理重启期间，我们看到了波纹管日志消息（即使对于主题和__consumer_offsets - > WARN由于需求失败而发现损坏的索引文件:)
由于时区更改导致Kafka代理重启时__consumer_offsets被破坏，它是否真的将消费者偏移重置为0？在此消息之后，我们再次重播了消息 .
WARN由于要求失败而发现损坏的索引文件：找到损坏的索引，索引文件（/app/kafka_2.12-0.11.0.2/data/__consumer_offsets-21/00000000000000002076.index）的大小非零，但最后一个偏移量是2076年不大于基准偏差2076.} . 删除/app/kafka_2.12-0.11.0.2/data/__consumer_offsets-21/00000000000000002076.timeindex,/app/kafka_2.12-0.11.0.2/data/__consumer_offsets-21/00000000000000002076.index,/app/kafka_2.12 -0.11.0.2 / data / __ consumer_offsets-21 / 00000000000000002076.txnindex和重建索引...（kafka.log.Log）
我们如何解决消费者抵消不会回归零（0）？
1 回答
删除索引文件 .
此问题是基于索引无法匹配的日志文件 . 这个问题存在很久，恢复方式是删除索引文件，它将重新创建 .