(kafka) branch trunk updated: MINOR: Fix error message for streams group reset (#22600)

[schofielaj]

This is an automated email from the ASF dual-hosted git repository.

AndrewJSchofield 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 96268b19468 MINOR: Fix error message for streams group reset (#22600)
96268b19468 is described below

commit 96268b194686d1979b295ce802aa455b8b773be1
Author: Andrew Schofield <aschofi...@confluent.io>
AuthorDate: Wed Jun 17 14:12:01 2026 +0100

    MINOR: Fix error message for streams group reset (#22600)
    
    This PR fixes a tiny problem in the error message for missing command
    options in `kafka-streams-groups.sh`.
    
    Before:
    
    ```
    % bin/kafka-streams-groups.sh --bootstrap-server localhost:9092
    --reset-offsets --group CG1 --dry-run
    One of the reset scopes should be defined: --all-topics, --topic.
    ```
    
    In this tool, `--all-topics` and `--topic` are not valid options. They
    should be `--all-input-topics` and `--input-topic`.
    
    After:
    
    ```
    % bin/kafka-streams-groups.sh --bootstrap-server localhost:9092
    --reset-offsets --group CG1 --dry-run
    One of the reset scopes should be defined: --all-input-topics,
    --input-topic.
    ```
    
    Reviewers: Lucas Brutschy <lbruts...@confluent.io>
---
 .../main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java 
b/tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java
index 8e40d81228d..92d03758fd0 100644
--- 
a/tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java
+++ 
b/tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java
@@ -958,7 +958,7 @@ public class StreamsGroupCommand {
                 return partitions;
             } else {
                 if (!opts.options.has(opts.resetFromFileOpt))
-                    CommandLineUtils.printUsageAndExit(opts.parser, "One of 
the reset scopes should be defined: --all-topics, --topic.");
+                    CommandLineUtils.printUsageAndExit(opts.parser, "One of 
the reset scopes should be defined: --all-input-topics, --input-topic.");
 
                 return List.of();
             }