(kafka) branch 4.3 updated: HOTFIX: add missing code changes are cherry-pick

[mjsax]

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

mjsax pushed a commit to branch 4.3
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/4.3 by this push:
     new ef8e8bdcbd1 HOTFIX: add missing code changes are cherry-pick
ef8e8bdcbd1 is described below

commit ef8e8bdcbd1afe86c43c78fe325605fe5a1921f3
Author: Matthias J. Sax <matth...@ibm.com>
AuthorDate: Mon Aug 3 14:11:13 2026 -0700

    HOTFIX: add missing code changes are cherry-pick
    
    The cherry-pick of https://github.com/apache/kafka/pull/22778 into 4.3
    was not clean, and the commit does not contain all changes.
    
    This PR fixed the broken branch.
---
 .../consumer/internals/StreamsGroupHeartbeatRequestManagerTest.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManagerTest.java
 
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManagerTest.java
index 55bd6c1cbe9..bb9e2767660 100644
--- 
a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManagerTest.java
+++ 
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManagerTest.java
@@ -71,6 +71,7 @@ import static 
org.apache.kafka.common.requests.StreamsGroupHeartbeatRequest.LEAV
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertInstanceOf;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
 import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -1707,7 +1708,9 @@ class StreamsGroupHeartbeatRequestManagerTest {
                 )
             );
 
-            completeSuccessfulHeartbeat(heartbeatRequestManager, response);
+            final NetworkClientDelegate.PollResult result = 
heartbeatRequestManager.poll(time.milliseconds());
+            assertEquals(1, result.unsentRequests.size());
+            result.unsentRequests.get(0).handler().onComplete(response);
 
             final StreamsRebalanceData.EndpointPartitions endpointPartitions = 
streamsRebalanceData.partitionsByHost()
                 .get(new StreamsRebalanceData.HostInfo("localhost", 8080));