dongnuo123 commented on code in PR #14675:
URL: https://github.com/apache/kafka/pull/14675#discussion_r1391629976
##########
core/src/test/scala/unit/kafka/admin/ListConsumerGroupTest.scala:
##########
@@ -29,7 +29,7 @@ import org.junit.jupiter.params.provider.ValueSource
class ListConsumerGroupTest extends ConsumerGroupCommandTest {
@ParameterizedTest
- @ValueSource(strings = Array("zk", "kraft"))
+ @ValueSource(strings = Array("zk", "kraft", "kraft+kip848"))
def testListConsumerGroups(quorum: String): Unit = {
Review Comment:
It doesn't work for kraft+kip848. If changing
GroupCoordinatorService#ListGroups with the same way of adding the futures as
describeGroups, this test passes. Not sure why
--
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]
