(kafka) branch trunk updated: KAFKA-19533: Correct the docs of 'messages' for `kafka-consumer-perf-test.sh` and `kafka-share-consumer-perf-test.sh (#20217)

[frankvicky]

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

frankvicky 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 7738db9b2d2 KAFKA-19533: Correct the docs of 'messages' for 
`kafka-consumer-perf-test.sh` and `kafka-share-consumer-perf-test.sh (#20217)
7738db9b2d2 is described below

commit 7738db9b2d2ce33d309fc24b4eebdbc736cf4bb2
Author: Lan Ding <isdin...@163.com>
AuthorDate: Tue Jul 22 22:37:49 2025 +0800

    KAFKA-19533: Correct the docs of 'messages' for 
`kafka-consumer-perf-test.sh` and `kafka-share-consumer-perf-test.sh (#20217)
    
    The descrption "REQUIRED: The number of messages to send or consume" is
    not correct, since those tools do NOT send any records.
    
    Reviewers: TengYao Chi <frankvi...@apache.org>
---
 tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java     | 2 +-
 .../src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java 
b/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java
index 0bbc953293f..60b4b37abe4 100644
--- a/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java
+++ b/tools/src/main/java/org/apache/kafka/tools/ConsumerPerformance.java
@@ -298,7 +298,7 @@ public class ConsumerPerformance {
                 .describedAs("milliseconds")
                 .ofType(Long.class)
                 .defaultsTo(10_000L);
-            numMessagesOpt = parser.accepts("messages", "REQUIRED: The number 
of messages to send or consume")
+            numMessagesOpt = parser.accepts("messages", "REQUIRED: The number 
of messages to consume.")
                 .withRequiredArg()
                 .describedAs("count")
                 .ofType(Long.class);
diff --git 
a/tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java 
b/tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java
index 9e3f0ff0152..bb0aaba89d5 100644
--- a/tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java
+++ b/tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java
@@ -334,7 +334,7 @@ public class ShareConsumerPerformance {
                     .describedAs("milliseconds")
                     .ofType(Long.class)
                     .defaultsTo(10_000L);
-            numMessagesOpt = parser.accepts("messages", "REQUIRED: The number 
of messages to send or consume")
+            numMessagesOpt = parser.accepts("messages", "REQUIRED: The number 
of messages to consume.")
                     .withRequiredArg()
                     .describedAs("count")
                     .ofType(Long.class);