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
);