我引用了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.