java Kafka将偏移重置为最早的偏移

1 周，3 日 Questions & Answers 878

当kafka崩溃时（由于硬件问题-存储不足或1个节点断开连接），My kafka服务器会将使用者组偏移重置为最早的偏移量。这是我第二次遇到这个问题，我无法轻松地将偏移量重新启动到事件发生前的最后一个小时（我可以在zookeeper中手动设置每个分区的偏移量，但每个主题有100个分区，我们有20个主题）

我不知道问题出在哪里（动物园管理员？卡夫卡？消费者？制片人？）。这只发生在卡夫卡从崩溃中恢复过来的时候。我不知道有任何错误或警告