(kafka) branch trunk updated: MINOR: Fix GroupCoordinatorShardTest stubbing (#14637)

[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 a64037cdef6 MINOR: Fix GroupCoordinatorShardTest stubbing (#14637)
a64037cdef6 is described below

commit a64037cdef6163002c6aae1b37463a267f1bff4b
Author: Jay Wang <xdddxyyyxzzz...@gmail.com>
AuthorDate: Wed Nov 15 16:45:11 2023 +0900

    MINOR: Fix GroupCoordinatorShardTest stubbing (#14637)
    
    This patch fixes incorrect stubs in GroupCoordinatorShardTest.
    
    Reviewers: David Jacot <dja...@confluent.io>
---
 .../org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java
 
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java
index c95e9459285..ee8003b29bb 100644
--- 
a/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java
+++ 
b/group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorShardTest.java
@@ -95,7 +95,7 @@ public class GroupCoordinatorShardTest {
             new ConsumerGroupHeartbeatResponseData()
         );
 
-        when(coordinator.consumerGroupHeartbeat(
+        when(groupMetadataManager.consumerGroupHeartbeat(
             context,
             request
         )).thenReturn(result);
@@ -122,7 +122,7 @@ public class GroupCoordinatorShardTest {
             new OffsetCommitResponseData()
         );
 
-        when(coordinator.commitOffset(
+        when(offsetMetadataManager.commitOffset(
             context,
             request
         )).thenReturn(result);