我引用了https://www.confluent.io/blog/data-reprocessing-with-kafka-streams-resetting-a-streams-application/ 并尝试使用kafka streams应用程序重置工具对kafka streams应用程序进行重置。但即使我做了所有的先决条件和必要的步骤,当我检查重置主题偏移量时 /opt/cloudera/parcels/KAFKA/lib/kafka/bin/kafka-consumer-groups.sh
,当前偏移量仍然不是0。
有人能帮忙吗?非常感谢。
1条答案
按热度按时间31moq8wy1#
根据您使用的版本,重置工具会提交“起始偏移量”的0——如果您的主题被保留并且被截断,“起始偏移量”不再是0。
根据设计,这实际上比提交零要好,因为在这种情况下,在应用程序重新启动时,零将是无效的偏移量
auto.offset.reset
将触发(如果它没有配置为“最早”,您将得到一些不希望的行为)。您可以通过
bin/kafka-run-class.sh kafka.tools.GetOffsetShell
.