root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: change the default linger time in the new coordinator (#18274)

This commit is contained in:
Jeff Kim 2024-12-19 16:54:23 -05:00
parent e8060720c2
commit 90ef7058e0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java
View File

@ -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.";