(kafka) branch trunk updated: KAFKA-19102 Enhance the docs of group.coordinator.append.linger.ms (#19451)

[frankvicky]

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

frankvicky 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 dced8bfb38c KAFKA-19102 Enhance the docs of 
group.coordinator.append.linger.ms (#19451)
dced8bfb38c is described below

commit dced8bfb38c611011630bffddec2cd893dfe2e7f
Author: Ken Huang <s7133...@gmail.com>
AuthorDate: Mon Apr 14 22:14:56 2025 +0800

    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 <kiting...@gmail.com>, Chia-Ping Tsai
     <chia7...@gmail.com>, PoAn Yang <pay...@apache.org>
---
 .../org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java    | 4 +++-
 1 file changed, 3 insertions(+), 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 6a436ed09c4..ece60a36dba 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
@@ -66,7 +66,9 @@ public class GroupCoordinatorConfig {
         Group.GroupType.CONSUMER.toString());
     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.";
+        "wait for writes to accumulate before flushing them to disk. 
Increasing this value improves write efficiency and batch size, " +
+        "but also increases the response latency for requests, as the 
coordinator must wait for batches to be flushed to " +
+        "disk before completing request processing. Transactional writes are 
not accumulated.";
     public static final int GROUP_COORDINATOR_APPEND_LINGER_MS_DEFAULT = 5;
 
     public static final String GROUP_COORDINATOR_NUM_THREADS_CONFIG = 
"group.coordinator.threads";