复位消费者在卡夫卡0.10

偏差在0.10，似乎我们可以重新与偏移到指定的位置寻找（）的编写代码复位消费者在卡夫卡0.10

短是有一个命令行util的这个？到目前为止，这似乎不是那么回事？

2016-07-07 user432024

与其名称暗示相反，您可以对非Kafka Streams应用程序使用'kafka-streams-application-reset'脚本'$ KAFKA_HOME/bin/kafka-streams-application-reset.sh --zookeeper zk：2181 --application-id myGroupId --input-topics myTopic' – Raf

'kafka-streams-application-reset'只会重置为最早的偏移位置。它不会让您重置为_specific_位置 – sworisbreathing

我刚刚实现了一个简单的命令行工具 - https://github.com/serejja/kafka-offset-mgr。

如果有必要，随意试用并发布问题/ PR。

来源

2016-07-08 12:49:50 serejja

谢谢！这正是我需要的。 – Brandon

复位消费者在卡夫卡0.10

回答

相关问题