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 e1deeb4b914 MINOR: Set default group.consumer.migration.policy to
BIDIRECTIONAL (#17295)
e1deeb4b914 is described below
commit e1deeb4b914a3f9a586ff627254f7424b339f580
Author: Dongnuo Lyu <[email protected]>
AuthorDate: Fri Sep 27 02:13:11 2024 -0400
MINOR: Set default group.consumer.migration.policy to BIDIRECTIONAL (#17295)
This is a small patch to change the default value of
group.consumer.migration.policy to BIDIRECTIONAL.
Reviewers: David Jacot <[email protected]>
---
.../java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 a6ecc2319ad..e30dcdac08a 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
@@ -125,7 +125,7 @@ public class GroupCoordinatorConfig {
));
public static final String CONSUMER_GROUP_MIGRATION_POLICY_CONFIG =
"group.consumer.migration.policy";
- public static final String CONSUMER_GROUP_MIGRATION_POLICY_DEFAULT =
ConsumerGroupMigrationPolicy.DISABLED.toString();
+ public static final String CONSUMER_GROUP_MIGRATION_POLICY_DEFAULT =
ConsumerGroupMigrationPolicy.BIDIRECTIONAL.toString();
public static final String CONSUMER_GROUP_MIGRATION_POLICY_DOC = "The
config that enables converting the non-empty classic group using the consumer
embedded protocol to the non-empty consumer group using the consumer group
protocol and vice versa; " +
"conversions of empty groups in both directions are always enabled
regardless of this policy. " +
ConsumerGroupMigrationPolicy.BIDIRECTIONAL + ": both upgrade from
classic group to consumer group and downgrade from consumer group to classic
group are enabled, " +
