You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/05/19 23:29:29 UTC
kafka git commit: MINOR: improve descriptions of Streams reset tool
options
Repository: kafka
Updated Branches:
refs/heads/trunk 61bab2d87 -> 338857e1c
MINOR: improve descriptions of Streams reset tool options
Author: Matthias J. Sax <ma...@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 <ma...@confluent.io>
Authored: Fri May 19 16:29:25 2017 -0700
Committer: Guozhang Wang <wa...@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);