From 340b9a1be09de638b71639b3afc5acdede5bf8d4 Mon Sep 17 00:00:00 2001
From: Sushant Mahajan <smahajan@confluent.io>
Date: Fri, 23 May 2025 16:09:33 +0530
Subject: [PATCH] HOTFIX: Fix build issue due to alter offsets.

---
 .../apache/kafka/coordinator/group/GroupMetadataManager.java   | 2 +-
 .../kafka/coordinator/group/GroupMetadataManagerTest.java      | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
index 0d153dc559770..39a179343d595 100644
--- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
+++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
@@ -8163,7 +8163,7 @@ public Map.Entry<AlterShareGroupOffsetsResponseData, InitializeShareGroupStatePa
             }
         });
 
-        addInitializingTopicsRecords(groupId, records, initializingTopics);
+        addInitializingTopicsRecords(groupId, records, attachInitValue(initializingTopics));
         return Map.entry(
             new AlterShareGroupOffsetsResponseData()
                 .setResponses(alterShareGroupOffsetsResponseTopics),
diff --git a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
index 9c644bb7e13a6..b2e3a3e4acc90 100644
--- a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
+++ b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java
@@ -21714,7 +21714,8 @@ public void testShareGroupInitializeSuccess() {
         CoordinatorRecord record = newShareGroupStatePartitionMetadataRecord(groupId, Map.of(), snapshotMetadataInitializeRecordMap, Map.of());
 
         assertNull(result.response());
-        assertEquals(List.of(record), result.records());
+        assertEquals(1, result.records().size());
+        assertRecordEquals(record, result.records().get(0));
         // Make sure the timeline map is not modified yet.
         assertEquals(snapshotMetadataInitializeRecordMap, context.groupMetadataManager.shareGroupStatePartitionMetadata().get(groupId).initializingTopics());
     }