Skip to content

Commit 03c4d5f

Browse files
dajacomkreddy
authored andcommitted
KAFKA-18320; Ensure that assignors are at the right place (apache#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 <[email protected]>, Jeff Kim <[email protected]>
1 parent 3d33eca commit 03c4d5f

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfigTest.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,19 @@ public class GroupCoordinatorConfigTest {
4444
GroupCoordinatorConfig.CONSUMER_GROUP_CONFIG_DEF,
4545
GroupCoordinatorConfig.SHARE_GROUP_CONFIG_DEF);
4646

47+
@Test
48+
public void testConsumerGroupAssignorsDefault() {
49+
// The full class name of the assignors is part of our public api. Hence,
50+
// we should ensure that they are not changed by mistake.
51+
assertEquals(
52+
List.of(
53+
"org.apache.kafka.coordinator.group.assignor.UniformAssignor",
54+
"org.apache.kafka.coordinator.group.assignor.RangeAssignor"
55+
),
56+
GroupCoordinatorConfig.CONSUMER_GROUP_ASSIGNORS_DEFAULT
57+
);
58+
}
59+
4760
@Test
4861
public void testConfigs() {
4962
Map<String, Object> configs = new HashMap<>();

0 commit comments

Comments
 (0)