You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ma...@apache.org on 2025/01/07 12:53:56 UTC

(kafka) branch trunk updated: MINOR: Update Consumer group timeout default to 30 sec (#16406)

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

manikumar 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 ea3459ee5db MINOR: Update Consumer group timeout default to 30 sec (#16406)
ea3459ee5db is described below

commit ea3459ee5db3870e2d68a65de9babf8ccb3e4fbf
Author: NICOLAS GUYOMAR <ni...@gmail.com>
AuthorDate: Tue Jan 7 13:53:49 2025 +0100

    MINOR: Update Consumer group timeout default to 30 sec (#16406)
    
    30 sec is more inline with the default request.timeout.ms and is still very acceptable for a CLI interaction in my opinion
    
    Reviewers: Manikumar Reddy <ma...@gmail.com>
---
 .../apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java b/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java
index 48d51622e9c..6d10a4088b4 100644
--- a/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java
+++ b/tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java
@@ -151,7 +151,7 @@ public class ConsumerGroupCommandOptions extends CommandDefaultOptions {
             .withRequiredArg()
             .describedAs("timeout (ms)")
             .ofType(Long.class)
-            .defaultsTo(5000L);
+            .defaultsTo(30000L);
         commandConfigOpt = parser.accepts("command-config", COMMAND_CONFIG_DOC)
             .withRequiredArg()
             .describedAs("command config property file")