lianetm commented on code in PR #16312:
URL: https://github.com/apache/kafka/pull/16312#discussion_r1645002348
##########
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##########
@@ -696,21 +721,23 @@ public void
testDelayedReconciliationResultAppliedWhenTargetChangedWithMetadataU
// Member receives and reconciles topic1-partition0
Uuid topicId1 = Uuid.randomUuid();
String topic1 = "topic1";
+
when(commitRequestManager.maybeAutoCommitSyncBeforeRevocation(anyLong())).thenReturn(CompletableFuture.completedFuture(null));
MembershipManagerImpl membershipManager =
mockMemberSuccessfullyReceivesAndAcksAssignment(topicId1,
topic1, Collections.singletonList(0));
membershipManager.onHeartbeatRequestSent();
assertEquals(MemberState.STABLE, membershipManager.state());
- clearInvocations(membershipManager, subscriptionState);
+ //clearInvocations(membershipManager, subscriptionState);
Review Comment:
let's remove the comment if we don't need the line anymore
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
