feyman2016 commented on a change in pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#discussion_r429504705
##########
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##########
@@ -119,7 +122,9 @@
+ "* This tool will not clean up the local state on the stream
application instances (the persisted "
+ "stores used to cache aggregation results).\n"
+ "You need to call KafkaStreams#cleanUp() in your application or
manually delete them from the "
- + "directory specified by \"state.dir\" configuration
(/tmp/kafka-streams/<application.id> by default).\n\n"
+ + "directory specified by \"state.dir\" configuration
(/tmp/kafka-streams/<application.id> by default).\n"
+ + "*Please use the \"--force\" option to force remove active
members in case long session "
Review comment:
Indeed, updated
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
