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 f9d502b6aff MINOR: Clarify group.consumer.assignors doc about default
assignor change (#22039)
f9d502b6aff is described below
commit f9d502b6aff8fc599aa9bfc93c03253db9e43e99
Author: David Jacot <[email protected]>
AuthorDate: Tue Apr 14 18:05:53 2026 +0200
MINOR: Clarify group.consumer.assignors doc about default assignor change
(#22039)
Changing the default server-side assignor does not trigger a rebalance
for existing groups. The new default takes effect on the next rebalance.
This patch clarifies that behavior in the config documentation.
Reviewers: Lianet Magrans <[email protected]>
---
.../java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java | 1 +
1 file changed, 1 insertion(+)
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 b5303be53b1..6d04a812ab4 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
@@ -216,6 +216,7 @@ public class GroupCoordinatorConfig {
public static final String CONSUMER_GROUP_ASSIGNORS_CONFIG =
"group.consumer.assignors";
public static final String CONSUMER_GROUP_ASSIGNORS_DOC = "The server side
assignors as a list of either names for builtin assignors or full class names
for customer assignors. " +
"The first one in the list is considered as the default assignor to be
used in the case where the consumer does not specify an assignor. " +
+ "Changing the default assignor does not trigger a rebalance for
existing groups; the new default takes effect on the next rebalance. " +
"The supported builtin assignors are: " +
CONSUMER_GROUP_BUILTIN_ASSIGNORS.stream().map(ConsumerGroupPartitionAssignor::name).collect(Collectors.joining(",
")) + ".";
public static final List<String> CONSUMER_GROUP_ASSIGNORS_DEFAULT =
CONSUMER_GROUP_BUILTIN_ASSIGNORS
.stream()