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")