lianetm commented on PR #15844: URL: https://github.com/apache/kafka/pull/15844#issuecomment-2145677008
Hey @kirktrue , this is the simple integration test I was suggesting on the [other timeout PR](https://github.com/apache/kafka/pull/15640#issuecomment-2117763853), that should be an easy way to ensure that we're being able to fetch offsets and make progress on continuous poll(ZERO), which is what this PR should unblock I expect (just as guidance, needs tweaks to ensure TestUtils polls with 0). Leaving it here in case it helps validate the changes: ``` // Ensure TestUtils polls with ZERO. This fails for the new consumer only. @ParameterizedTest(name = TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames) @MethodSource(Array("getTestQuorumAndGroupProtocolParametersAll")) def testPollEventuallyReturnsRecordsWithZeroTimeout(quorum: String, groupProtocol: String): Unit = { val numMessages = 100 val producer = createProducer() sendRecords(producer, numMessages, tp) val consumer = createConsumer() consumer.subscribe(Set(topic).asJava) val records = awaitNonEmptyRecords(consumer, tp) assertEquals(numMessages, records.count()) } ``` -- 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
