Repository: kafka Updated Branches: refs/heads/trunk 61bab2d87 -> 338857e1c
MINOR: improve descriptions of Streams reset tool options Author: Matthias J. Sax <[email protected]> Reviewers: Bill Bejeck, Guozhang Wang Closes #3107 from mjsax/minor-reset-tool-options Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/338857e1 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/338857e1 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/338857e1 Branch: refs/heads/trunk Commit: 338857e1c2c2bb0c6011fcab477818102b95cb56 Parents: 61bab2d Author: Matthias J. Sax <[email protected]> Authored: Fri May 19 16:29:25 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Fri May 19 16:29:25 2017 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/tools/StreamsResetter.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/338857e1/core/src/main/scala/kafka/tools/StreamsResetter.java ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/tools/StreamsResetter.java b/core/src/main/scala/kafka/tools/StreamsResetter.java index 3a778ee..4be5f37 100644 --- a/core/src/main/scala/kafka/tools/StreamsResetter.java +++ b/core/src/main/scala/kafka/tools/StreamsResetter.java @@ -138,7 +138,7 @@ public class StreamsResetter { private void parseArguments(final String[] args) throws IOException { final OptionParser optionParser = new OptionParser(); - applicationIdOption = optionParser.accepts("application-id", "The Kafka Streams application ID (application.id)") + applicationIdOption = optionParser.accepts("application-id", "The Kafka Streams application ID (application.id).") .withRequiredArg() .ofType(String.class) .describedAs("id") @@ -148,7 +148,7 @@ public class StreamsResetter { .ofType(String.class) .defaultsTo("localhost:9092") .describedAs("urls"); - zookeeperOption = optionParser.accepts("zookeeper", "Format: HOST:POST") + zookeeperOption = optionParser.accepts("zookeeper", "Zookeeper url with format: HOST:POST") .withRequiredArg() .ofType(String.class) .defaultsTo("localhost:2181") @@ -163,7 +163,7 @@ public class StreamsResetter { .ofType(String.class) .withValuesSeparatedBy(',') .describedAs("list"); - dryRunOption = optionParser.accepts("dry-run", "Option to indicate to run streams reset tool to display actions it will perform"); + dryRunOption = optionParser.accepts("dry-run", "Display the actions that would be performed without executing the reset commands."); try { options = optionParser.parse(args);
