You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by je...@apache.org on 2024/12/20 15:20:17 UTC
(kafka) branch 4.0 updated: MINOR: change the default linger time in the new coordinator (#18274)
This is an automated email from the ASF dual-hosted git repository.
jeffkbkim pushed a commit to branch 4.0
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/4.0 by this push:
new 90ef7058e02 MINOR: change the default linger time in the new coordinator (#18274)
90ef7058e02 is described below
commit 90ef7058e026578e49b4e1aba758f2e28ffbe2cd
Author: Jeff Kim <ki...@gmail.com>
AuthorDate: Thu Dec 19 16:54:23 2024 -0500
MINOR: change the default linger time in the new coordinator (#18274)
---
.../java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
index 5dc576a5dd3..f1ae15cbc7a 100644
--- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
+++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
@@ -82,7 +82,7 @@ public class GroupCoordinatorConfig {
public static final String GROUP_COORDINATOR_APPEND_LINGER_MS_CONFIG = "group.coordinator.append.linger.ms";
public static final String GROUP_COORDINATOR_APPEND_LINGER_MS_DOC = "The duration in milliseconds that the coordinator will " +
"wait for writes to accumulate before flushing them to disk. Transactional writes are not accumulated.";
- public static final int GROUP_COORDINATOR_APPEND_LINGER_MS_DEFAULT = 10;
+ public static final int GROUP_COORDINATOR_APPEND_LINGER_MS_DEFAULT = 5;
public static final String GROUP_COORDINATOR_NUM_THREADS_CONFIG = "group.coordinator.threads";
public static final String GROUP_COORDINATOR_NUM_THREADS_DOC = "The number of threads used by the group coordinator.";