C0urante commented on code in PR #16519:
URL: https://github.com/apache/kafka/pull/16519#discussion_r1670766833
##########
connect/runtime/src/test/java/org/apache/kafka/connect/integration/OffsetsApiIntegrationTest.java:
##########
@@ -927,6 +955,53 @@ private Map<String, String> baseSourceConnectorConfigs() {
return props;
}
+ /**
+ * Wait for a consumer group to exist and have the expected number of
members.
+ * @param kafkaCluster the Kafka cluster that should host the group; may
not be null
+ * @param groupId the ID of the group; may not be null
+ * @param expectedMembers the exact number of members that should be in
the group; may not be null
+ * @throws InterruptedException if the thread is interrupted while waiting
for the consumer
+ * group to form
+ */
+ private void verifyConsumerGroupMembers(
Review Comment:
TODO: If this method is useful, it will obviate the existing
`modifySinkConnectorOffsetsWithRetry` method, which we will then be able to
remove.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
