(kafka) branch trunk updated: MINOR: Move group coordinator UnionSet to util package (#23518)

[sq...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

squah-confluent 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 7943e850736 MINOR: Move group coordinator UnionSet to util package (#23518)
7943e850736 is described below

commit 7943e8507363854d262757cb1017062b2cf2206b
Author: Sean Quah <sq...@confluent.io>
AuthorDate: Mon Sep 21 16:09:00 2026 +0100

    MINOR: Move group coordinator UnionSet to util package (#23518)
    
    When UnionSet was added, there was no util package in the group
    coordinator. There is one now, so move it there.
    
    Reviewers: David Jacot <da...@apache.org>
---
 .../apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java  | 1 +
 .../coordinator/group/modern/consumer/CurrentAssignmentBuilder.java     | 2 +-
 .../org/apache/kafka/coordinator/group/{modern => util}/UnionSet.java   | 2 +-
 .../kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java     | 1 +
 .../apache/kafka/coordinator/group/{modern => util}/UnionSetTest.java   | 2 +-
 5 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java
index 6937b95eaf6..2556fba83bf 100644
--- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java
+++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java
@@ -29,6 +29,7 @@ import org.apache.kafka.coordinator.group.api.assignor.SubscriptionType;
 import org.apache.kafka.coordinator.group.modern.consumer.ConsumerGroupMember;
 import org.apache.kafka.coordinator.group.modern.consumer.ResolvedRegularExpression;
 import org.apache.kafka.coordinator.group.modern.share.ShareGroupMember;
+import org.apache.kafka.coordinator.group.util.UnionSet;
 
 import java.util.ArrayList;
 import java.util.Collections;
diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java
index 2d3ea1304de..4b9d1c8c1c0 100644
--- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java
+++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java
@@ -23,7 +23,7 @@ import org.apache.kafka.coordinator.common.runtime.CoordinatorMetadataImage;
 import org.apache.kafka.coordinator.group.modern.Assignment;
 import org.apache.kafka.coordinator.group.modern.MemberState;
 import org.apache.kafka.coordinator.group.modern.TopicIds;
-import org.apache.kafka.coordinator.group.modern.UnionSet;
+import org.apache.kafka.coordinator.group.util.UnionSet;
 
 import java.util.HashMap;
 import java.util.HashSet;
diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/UnionSet.java
similarity index 99%
rename from group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java
rename to group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/UnionSet.java
index 95c6d9bd863..11c7cbf17f3 100644
--- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java
+++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/UnionSet.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.kafka.coordinator.group.modern;
+package org.apache.kafka.coordinator.group.util;
 
 import java.lang.reflect.Array;
 import java.util.Collection;
diff --git a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java
index b13ea51f441..5ad1476010b 100644
--- a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java
+++ b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilderTest.java
@@ -28,6 +28,7 @@ import org.apache.kafka.coordinator.group.api.assignor.PartitionAssignor;
 import org.apache.kafka.coordinator.group.api.assignor.SubscriptionType;
 import org.apache.kafka.coordinator.group.modern.consumer.ConsumerGroupMember;
 import org.apache.kafka.coordinator.group.modern.consumer.ResolvedRegularExpression;
+import org.apache.kafka.coordinator.group.util.UnionSet;
 
 import org.junit.jupiter.api.Test;
 
diff --git a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/UnionSetTest.java b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/util/UnionSetTest.java
similarity index 98%
rename from group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/UnionSetTest.java
rename to group-coordinator/src/test/java/org/apache/kafka/coordinator/group/util/UnionSetTest.java
index fc65baab791..72bf8dd8331 100644
--- a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/modern/UnionSetTest.java
+++ b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/util/UnionSetTest.java
@@ -14,7 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.apache.kafka.coordinator.group.modern;
+package org.apache.kafka.coordinator.group.util;
 
 import org.junit.jupiter.api.Test;