rreddy-22 commented on code in PR #15150:
URL: https://github.com/apache/kafka/pull/15150#discussion_r1458121585
##########
core/src/test/scala/unit/kafka/admin/ConsumerGroupCommandTest.scala:
##########
@@ -116,6 +123,18 @@ class ConsumerGroupCommandTest extends
KafkaServerTestHarness {
}
object ConsumerGroupCommandTest {
+ // We want to test the following combinations:
+ // * ZooKeeper and the classic group protocol.
+ // * KRaft and the classic group protocol.
+ // * KRaft with the new group coordinator enabled and the classic group
protocol.
+ // * KRaft with the new group coordinator enabled and the consumer group
protocol.
+ def getTestQuorumAndGroupProtocolParametersAll:
java.util.stream.Stream[Arguments] = {
Review Comment:
I wasn't able to re use it so I added the code here but I can double check
--
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
