mjsax commented on a change in pull request #10411:
URL: https://github.com/apache/kafka/pull/10411#discussion_r604517220
##########
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##########
@@ -247,14 +247,13 @@ private void parseArguments(final String[] args) {
.describedAs("file name");
forceOption = optionParser.accepts("force", "Force the removal of
members of the consumer group (intended to remove stopped members if a long
session timeout was used). " +
"Make sure to shut down all stream applications when this
option is specified to avoid unexpected rebalances.");
- executeOption = optionParser.accepts("execute", "Execute the
command.");
+
+ // TODO: deprecated in 3.0 can be removed in a future release --
https://issues.apache.org/jira/browse/KAFKA-7606
+ executeOption = optionParser.accepts("execute", "This option is
deprecated and will be removed in a future release; it is not required to
specify this in order to execute the command");
Review comment:
We did not to do this for ZK flag, but should we also log/print if the
flag is used?
--
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
