root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

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 <squah@confluent.io>, Jeff Kim <jeff.kim@confluent.io>
This commit is contained in:
David Jacot 2025-01-31 16:51:28 +01:00 committed by GitHub
parent 0ff4dafb7d
commit d19b605210
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 13 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -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<String, Object> configs = new HashMap<>();