From d19b60521001697bc9d518cfc3d585e7b78d15a3 Mon Sep 17 00:00:00 2001 From: David Jacot Date: Fri, 31 Jan 2025 16:51:28 +0100 Subject: [PATCH] KAFKA-18320; Ensure that assignors are at the right place (#18750) The full class name of the assignors if part of our public api. Hence, we should ensure that they are not changed by mistake. This patch adds a unit test verifying them. Reviewers: Sean Quah , Jeff Kim --- .../group/GroupCoordinatorConfigTest.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java index 4956acaf3866b..213f55874d7bc 100644 --- a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java +++ b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java @@ -44,6 +44,19 @@ public class GroupCoordinatorConfigTest { GroupCoordinatorConfig.CONSUMER_GROUP_CONFIG_DEF, GroupCoordinatorConfig.SHARE_GROUP_CONFIG_DEF); + @Test + public void testConsumerGroupAssignorsDefault() { + // The full class name of the assignors is part of our public api. Hence, + // we should ensure that they are not changed by mistake. + assertEquals( + List.of( + "org.apache.kafka.coordinator.group.assignor.UniformAssignor", + "org.apache.kafka.coordinator.group.assignor.RangeAssignor" + ), + GroupCoordinatorConfig.CONSUMER_GROUP_ASSIGNORS_DEFAULT + ); + } + @Test public void testConfigs() { Map configs = new HashMap<>();