aliehsaeedii commented on code in PR #19646:
URL: https://github.com/apache/kafka/pull/19646#discussion_r2141033584
##########
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommandOptions.java:
##########
@@ -33,13 +33,18 @@
import static org.apache.kafka.tools.ToolsUtils.minus;
public class StreamsGroupCommandOptions extends CommandDefaultOptions {
+ private static final String NL = System.lineSeparator();
public static final Logger LOGGER =
LoggerFactory.getLogger(StreamsGroupCommandOptions.class);
public static final String BOOTSTRAP_SERVER_DOC = "REQUIRED: The server(s)
to connect to.";
public static final String GROUP_DOC = "The streams group we wish to act
on.";
+ private static final String ALL_GROUPS_DOC = "Apply to all streams
groups.";
+ private static final String INPUT_TOPIC_DOC = "The input topic whose
streams group information should be deleted or topic that should be included in
the reset offset process. " +
+ "In `reset-offsets` case, partitions can be specified using this
format: `topic1:0,1,2`, where 0,1,2 are the partition to be included in the
process. " +
+ "Reset-offsets also supports multiple topic inputs.";
+ private static final String ALL_INPUT_TOPICS_DOC = "Consider all topics
assigned to a group in the `reset-offsets` process.";
Review Comment:
>Also, topics aren't really assigned to a group.
I meant associated:|
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
