rajinisivaram commented on code in PR #17720:
URL: https://github.com/apache/kafka/pull/17720#discussion_r1840224877
##########
core/src/test/scala/integration/kafka/api/ConsumerRebootstrapTest.scala:
##########
@@ -87,3 +128,17 @@ class ConsumerRebootstrapTest extends RebootstrapTest {
producer.close()
}
}
+
+object ConsumerRebootstrapTest {
+
+ final val RebootstrapTestName =
s"${TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames}.useRebootstrapTriggerMs={2}"
+ def rebootstrapTestParams: stream.Stream[Arguments] = {
+ assertEquals(1,
getTestQuorumAndGroupProtocolParametersClassicGroupProtocolOnly_ZK_implicit.count())
Review Comment:
@omkreddy Thanks for the review. The code below is using only the first
entry. At the moment, there is only one entry, but I wanted to make sure that
if we added more in future, the test would get updated to include all.
--
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]
