(kafka) branch trunk updated: KAFKA-18320; Ensure that assignors are at the right place (#18750)

[dajac]

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 d19b6052100 KAFKA-18320; Ensure that assignors are at the right place 
(#18750)
d19b6052100 is described below

commit d19b60521001697bc9d518cfc3d585e7b78d15a3
Author: David Jacot <david.ja...@gmail.com>
AuthorDate: Fri Jan 31 16:51:28 2025 +0100

    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 <sq...@confluent.io>, Jeff Kim <jeff....@confluent.io>
---
 .../kafka/coordinator/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 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<String, Object> configs = new HashMap<>();