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

dajac 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 d9c77be2957 MINOR: Fix order in GroupCoordinatorConfig (#21563)
d9c77be2957 is described below

commit d9c77be2957f3f73ef07d194a4d739765a896a38
Author: David Jacot <[email protected]>
AuthorDate: Tue Feb 24 13:48:54 2026 +0100

    MINOR: Fix order in GroupCoordinatorConfig (#21563)
    
    This patch puts the `SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS*`
    constants where they should be in `GroupCoordinatorConfig`.
    
    Reviewers: Sean Quah <[email protected]>, Chia-Ping Tsai
     <[email protected]>
---
 .../kafka/coordinator/group/GroupCoordinatorConfig.java       | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

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 8bcfb6d1b92..bb969501f29 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
@@ -260,6 +260,12 @@ public class GroupCoordinatorConfig {
         SHARE_GROUP_BUILTIN_ASSIGNOR.name() + ".";
     public static final String SHARE_GROUP_ASSIGNORS_DEFAULT = 
SHARE_GROUP_BUILTIN_ASSIGNOR.name();
 
+    public static final String SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS_CONFIG 
= "group.share.initialize.retry.interval.ms";
+    // Because persister retries with exp backoff 5 times and upper cap of 30 
secs.
+    public static final int SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS_DEFAULT = 
30_000;
+    public static final String SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS_DOC = 
"Time elapsed before retrying initialize share group state request. " +
+        "If below offsets.commit.timeout.ms, then value of 
offsets.commit.timeout.ms is used.";
+
     ///
     /// Streams group configs
     ///
@@ -303,11 +309,6 @@ public class GroupCoordinatorConfig {
     public static final int STREAMS_GROUP_INITIAL_REBALANCE_DELAY_MS_DEFAULT = 
3000;
     public static final String STREAMS_GROUP_INITIAL_REBALANCE_DELAY_MS_DOC = 
"The amount of time the group coordinator will wait for more streams clients to 
join a new group before performing the first rebalance. A longer delay means 
potentially fewer rebalances.";
 
-    public static final String SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS_CONFIG 
= "group.share.initialize.retry.interval.ms";
-    // Because persister retries with exp backoff 5 times and upper cap of 30 
secs.
-    public static final int SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS_DEFAULT = 
30_000;
-    public static final String SHARE_GROUP_INITIALIZE_RETRY_INTERVAL_MS_DOC = 
"Time elapsed before retrying initialize share group state request. If below 
offsets.commit.timeout.ms, then value of offsets.commit.timeout.ms is used.";
-
     public static final Set<String> RECONFIGURABLE_CONFIGS = Set.of(
         CACHED_BUFFER_MAX_BYTES_CONFIG
     );

Reply via email to