kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: improve descriptions of Streams reset tool options
Date Fri, 19 May 2017 23:29:29 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 61bab2d87 -> 338857e1c


MINOR: improve descriptions of Streams reset tool options

Author: Matthias J. Sax <matthias@confluent.io>

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 <matthias@confluent.io>
Authored: Fri May 19 16:29:25 2017 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
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);


Mime
View raw message