在0.10版本中,似乎我们可以使用seek()将偏移量重置到特定位置。
除了编写代码之外,是否有命令行工具可供使用?目前看来似乎没有?
kafka-streams-application-reset
$KAFKA_HOME/bin/kafka-streams-application-reset.sh --zookeeper zk:2181 --application-id myGroupId --input-topics myTopic
kafka-streams-application-reset
脚本用于非Kafka Streams应用程序$KAFKA_HOME/bin/kafka-streams-application-reset.sh --zookeeper zk:2181 --application-id myGroupId --input-topics myTopic
。 - Rafkafka-streams-application-reset
只能将偏移量重置到最早的位置,无法将其重置到特定的位置。 - sworisbreathing