7
In 0,10 sembra siamo in grado di ripristinare l'offset in una posizione specifica con seek()reset dei consumatori compensato in Kafka 0.10
corto di scrivere codice c'è una riga di comando util per questo? Non sembra così, finora?
contrariamente a quello che suggerisce il nome, è possibile utilizzare lo script 'kafka-streams-application-reset' per le applicazioni non Kafka Streams $ $ KAFKA_HOME/bin/kafka-streams-application-reset.sh --zookeeper zk: 2181 --application-id myGroupId --input-topics myTopic' – Raf
'kafka-streams-application-reset' si reimposta solo nella posizione di offset più remota. Non ti consente di ripristinare la posizione _specific_ – sworisbreathing