This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a945bd4 MINOR: Update streamResetter option description (#11613)
a945bd4 is described below
commit a945bd45b85dee6a2d90833e365f1b48c11d66e4
Author: Luke Chen <[email protected]>
AuthorDate: Thu Jan 20 03:37:47 2022 +0800
MINOR: Update streamResetter option description (#11613)
Reviewers: Jorge Esteban Quilcate Otoya <[email protected]>,
Matthias J. Sax <[email protected]>
---
core/src/main/scala/kafka/tools/StreamsResetter.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/core/src/main/scala/kafka/tools/StreamsResetter.java
b/core/src/main/scala/kafka/tools/StreamsResetter.java
index 3b7e1cb..97cd9a0 100644
--- a/core/src/main/scala/kafka/tools/StreamsResetter.java
+++ b/core/src/main/scala/kafka/tools/StreamsResetter.java
@@ -111,8 +111,8 @@ public class StreamsResetter {
private final static String USAGE = "This tool helps to quickly reset an
application in order to reprocess "
+ "its data from scratch.\n"
- + "* This tool resets offsets of input topics to the earliest
available offset and it skips to the end of "
- + "intermediate topics (topics that are input and output topics,
e.g., used by deprecated through() method).\n"
+ + "* This tool resets offsets of input topics to the earliest
available offset (by default), or to a specific defined position"
+ + " and it skips to the end of intermediate topics (topics that
are input and output topics, e.g., used by deprecated through() method).\n"
+ "* This tool deletes the internal topics that were created by
Kafka Streams (topics starting with "
+ "\"<application.id>-\").\n"
+ "The tool finds these internal topics automatically. If the
topics flagged automatically for deletion by "
@@ -218,12 +218,14 @@ public class StreamsResetter {
.ofType(String.class)
.defaultsTo("localhost:9092")
.describedAs("urls");
- inputTopicsOption = optionParser.accepts("input-topics",
"Comma-separated list of user input topics. For these topics, the tool will
reset the offset to the earliest available offset.")
+ inputTopicsOption = optionParser.accepts("input-topics",
"Comma-separated list of user input topics. For these topics, the tool by
default will reset the offset to the earliest available offset. "
+ + "Reset to other offset position by appending other reset
offset option, ex: --input-topics foo --shift-by 5")
.withRequiredArg()
.ofType(String.class)
.withValuesSeparatedBy(',')
.describedAs("list");
- intermediateTopicsOption = optionParser.accepts("intermediate-topics",
"Comma-separated list of intermediate user topics (topics that are input and
output topics, e.g., used in the deprecated through() method). For these
topics, the tool will skip to the end.")
+ intermediateTopicsOption = optionParser.accepts("intermediate-topics",
"Comma-separated list of intermediate user topics (topics that are input and
output topics, "
+ + "e.g., used in the deprecated through() method). For these
topics, the tool will skip to the end.")
.withRequiredArg()
.ofType(String.class)
.withValuesSeparatedBy(',')
