7
yılında ofset biz birlikte belirli bir pozisyona ofset sıfırlayabilirsiniz görünüyor seek() kod yazmaSıfırlama tüketici 0,10 olarak kafka 0.10
Kısa bunun için util bir komut satırı var mı? Bu kadar uzak görünmüyor mu?
Adından da anlaşılacağı gibi, Kafka Streams uygulamaları için "kafka-stream-application-reset" betiğini kullanabilirsiniz. $ KAFKA_HOME/bin/kafka-streams-application-reset.sh --zookeeper zk: 2181 --application-id myGroupId --input-konuları myTopic – Raf
“kafka-stream-application-reset” sadece en erken ofset konumuna sıfırlanır. _specific_ pozisyonuna sıfırlanmanıza izin vermiyor – sworisbreathing