This is an automated email from the ASF dual-hosted git repository.
chia7712 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 7199019b155 MINOR: Remove early access warning for streams rebalance
protocol (#20873)
7199019b155 is described below
commit 7199019b1554a6b3771b9bafb89cb4ad6b954856
Author: Ming-Yen Chung <[email protected]>
AuthorDate: Fri Nov 14 18:14:47 2025 +0800
MINOR: Remove early access warning for streams rebalance protocol (#20873)
The streams rebalance protocol will go GA in AK 4.2 according to
StreamsVersion
https://github.com/apache/kafka/blob/b0a26bc2f485fa7ec05ba1b5f9e9120fd43abbf4/server-common/src/main/java/org/apache/kafka/server/common/StreamsVersion.java#L29
Reviewers: Lucas Brutschy <[email protected]>, Chia-Ping Tsai
<[email protected]>
---
.../org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java | 3 +--
1 file changed, 1 insertion(+), 2 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 e8a2f496639..2653be28b3e 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
@@ -63,8 +63,7 @@ public class GroupCoordinatorConfig {
/// Group coordinator configs
///
public static final String GROUP_COORDINATOR_REBALANCE_PROTOCOLS_CONFIG =
"group.coordinator.rebalance.protocols";
- public static final String GROUP_COORDINATOR_REBALANCE_PROTOCOLS_DOC =
"The list of enabled rebalance protocols." +
- "The " + Group.GroupType.STREAMS + " rebalance protocol is in
early access and therefore must not be used in production.";
+ public static final String GROUP_COORDINATOR_REBALANCE_PROTOCOLS_DOC =
"The list of enabled rebalance protocols.";
public static final List<String>
GROUP_COORDINATOR_REBALANCE_PROTOCOLS_DEFAULT = List.of(
Group.GroupType.CLASSIC.toString(),
Group.GroupType.CONSUMER.toString(),