lucasbru commented on code in PR #19548:
URL: https://github.com/apache/kafka/pull/19548#discussion_r2058862659
##########
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupCoordinatorServiceTest.java:
##########
@@ -1429,14 +1434,14 @@ public void testConsumerGroupDescribe() throws
InterruptedException, ExecutionEx
when(runtime.scheduleReadOperation(
ArgumentMatchers.eq("consumer-group-describe"),
ArgumentMatchers.eq(new
TopicPartition(Topic.GROUP_METADATA_TOPIC_NAME, 0)),
- ArgumentMatchers.any()
+ readOperationCaptor.capture()
Review Comment:
The argument here is a lambda that we cannot check directly. We need to
capture it, run it. Inside the lambda, we're calling the method with the list
to be checked. That's the testing complication here.
--
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
