TRBaldim · October 25, 2017 02:10
diff --git a/reset_kafka_consumer_group.sh b/reset_kafka_consumer_group.sh
 # After stopping all application instances, reset the application
 $ bin/kafka-streams-application-reset --application-id my-streams-app \
                                      --input-topics my-input-topic \
                                      --intermediate-topics rekeyed-topic \
                                      --bootstrap-servers brokerHost:9092 \
                                      --zookeeper zookeeperHost:2181
	# After stopping all application instances, reset the application
	$ bin/kafka-streams-application-reset --application-id my-streams-app \
	--input-topics my-input-topic \
	--intermediate-topics rekeyed-topic \
	--bootstrap-servers brokerHost:9092 \
	--zookeeper zookeeperHost:2181