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

schofielaj 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 f1675436e4f MINOR: Change share coord linger ms in line with group 
coord. (#18572)
f1675436e4f is described below

commit f1675436e4ffae551f7b4bb8764ad6bfb9062531
Author: Sushant Mahajan <smaha...@confluent.io>
AuthorDate: Thu Jan 16 18:46:17 2025 +0530

    MINOR: Change share coord linger ms in line with group coord. (#18572)
    
    Reviewers: Andrew Schofield <aschofi...@confluent.io>
---
 .../java/org/apache/kafka/coordinator/share/ShareCoordinatorConfig.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorConfig.java
 
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorConfig.java
index dcb72672792..f4a11abea8e 100644
--- 
a/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorConfig.java
+++ 
b/share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorConfig.java
@@ -69,7 +69,7 @@ public class ShareCoordinatorConfig {
     public static final String STATE_TOPIC_COMPRESSION_CODEC_DOC = 
"Compression codec for the share-group state topic.";
 
     public static final String APPEND_LINGER_MS_CONFIG = 
"share.coordinator.append.linger.ms";
-    public static final int APPEND_LINGER_MS_DEFAULT = 10;
+    public static final int APPEND_LINGER_MS_DEFAULT = 5;
     public static final String APPEND_LINGER_MS_DOC = "The duration in 
milliseconds that the share coordinator will wait for writes to accumulate 
before flushing them to disk.";
 
     public static final String STATE_TOPIC_PRUNE_INTERVAL_MS_CONFIG = 
"share.coordinator.state.topic.prune.interval.ms";

Reply via email to