(kafka) branch trunk updated: MINOR: Cleanup GroupCoordinatorRecordHelpers (#17718)

[chia7712]

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

chia7712 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 f7d2a8cd52c MINOR: Cleanup GroupCoordinatorRecordHelpers (#17718)
f7d2a8cd52c is described below

commit f7d2a8cd52ca2e88072e177f971c3bc85d842903
Author: David Jacot <dja...@confluent.io>
AuthorDate: Fri Nov 8 17:00:03 2024 +0100

    MINOR: Cleanup GroupCoordinatorRecordHelpers (#17718)
    
    Reviewers: Jeff Kim <jeff....@confluent.io>, Mickael Maison 
<mickael.mai...@gmail.com>, Chia-Ping Tsai <chia7...@gmail.com>
---
 .../group/GroupCoordinatorRecordHelpers.java       | 35 ++--------------------
 1 file changed, 3 insertions(+), 32 deletions(-)

diff --git 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java
 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java
index be912107504..b3aa3b9db77 100644
--- 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java
+++ 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java
@@ -360,35 +360,6 @@ public class GroupCoordinatorRecordHelpers {
         );
     }
 
-    /**
-     * Creates a ConsumerGroupCurrentMemberAssignment record.
-     *
-     * @param groupId   The consumer group id.
-     * @param member    The share group member.
-     * @return The record.
-     */
-    public static CoordinatorRecord newConsumerGroupCurrentAssignmentRecord(
-        String groupId,
-        ShareGroupMember member
-    ) {
-        return new CoordinatorRecord(
-            new ApiMessageAndVersion(
-                new ConsumerGroupCurrentMemberAssignmentKey()
-                    .setGroupId(groupId)
-                    .setMemberId(member.memberId()),
-                (short) 8
-            ),
-            new ApiMessageAndVersion(
-                new ConsumerGroupCurrentMemberAssignmentValue()
-                    .setMemberEpoch(member.memberEpoch())
-                    .setPreviousMemberEpoch(member.previousMemberEpoch())
-                    .setState(member.state().value())
-                    
.setAssignedPartitions(toTopicPartitions(member.assignedPartitions())),
-                (short) 0
-            )
-        );
-    }
-
     /**
      * Creates a ConsumerGroupCurrentMemberAssignment tombstone.
      *
@@ -731,7 +702,7 @@ public class GroupCoordinatorRecordHelpers {
      * @return The record.
      */
     public static CoordinatorRecord 
newShareGroupSubscriptionMetadataTombstoneRecord(
-            String groupId
+        String groupId
     ) {
         return new CoordinatorRecord(
             new ApiMessageAndVersion(
@@ -929,8 +900,8 @@ public class GroupCoordinatorRecordHelpers {
      * @return The record.
      */
     public static CoordinatorRecord 
newShareGroupCurrentAssignmentTombstoneRecord(
-            String groupId,
-            String memberId
+        String groupId,
+        String memberId
     ) {
         return new CoordinatorRecord(
             new ApiMessageAndVersion(