Skip to content

Commit dced8bf

Browse files
authored
KAFKA-19102 Enhance the docs of group.coordinator.append.linger.ms (#19451)
Update the `group.coordinator.append.linger.ms` document, alterting users to the potentail consequences of increasing value, It should explain that increasing that value would improves write efficiency but also increases response latency for requests. Reviewers: TengYao Chi <[email protected]>, Chia-Ping Tsai <[email protected]>, PoAn Yang <[email protected]>
1 parent fc21a15 commit dced8bf

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

Diff for: group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,9 @@ public class GroupCoordinatorConfig {
6666
Group.GroupType.CONSUMER.toString());
6767
public static final String GROUP_COORDINATOR_APPEND_LINGER_MS_CONFIG = "group.coordinator.append.linger.ms";
6868
public static final String GROUP_COORDINATOR_APPEND_LINGER_MS_DOC = "The duration in milliseconds that the coordinator will " +
69-
"wait for writes to accumulate before flushing them to disk. Transactional writes are not accumulated.";
69+
"wait for writes to accumulate before flushing them to disk. Increasing this value improves write efficiency and batch size, " +
70+
"but also increases the response latency for requests, as the coordinator must wait for batches to be flushed to " +
71+
"disk before completing request processing. Transactional writes are not accumulated.";
7072
public static final int GROUP_COORDINATOR_APPEND_LINGER_MS_DEFAULT = 5;
7173

7274
public static final String GROUP_COORDINATOR_NUM_THREADS_CONFIG = "group.coordinator.threads";

0 commit comments

Comments
 (0)