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 4956acaf386..213f55874d7 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<>();