[
https://issues.apache.org/jira/browse/KAFKA-17410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881034#comment-17881034
]
Lianet Magrans commented on KAFKA-17410:
----------------------------------------
[~frankvicky] this test is very noisy/flaky in trunk, and we already have
coverage for the new consumer in
AsyncKafkaConsumerTest.testPollThrowsInterruptExceptionIfInterrupted (passing
consistently), so it would make sense to me to leave it running only for the
classic consumer, what do you think?
In parallel, given that we may have an idea of what could be behind the
flakiness (but fix is in-flight), we can review it again once that fix goes in
(jiras related already). Makes sense?
If so, let me know if you have bandwidth for the PR just moving this back to
the classic consumer, with the reference to the existing test for the new
consumer. Happy to help with reviews. Thanks!
> Flaky test testPollThrowsInterruptExceptionIfInterrupted for new consumer
> -------------------------------------------------------------------------
>
> Key: KAFKA-17410
> URL: https://issues.apache.org/jira/browse/KAFKA-17410
> Project: Kafka
> Issue Type: Bug
> Components: clients, consumer
> Reporter: Lianet Magrans
> Assignee: TengYao Chi
> Priority: Major
> Labels: consumer-threading-refactor, flaky-test
>
> KafkaConsumerTest.testPollThrowsInterruptExceptionIfInterrupted is flaky for
> the new consumer (passing consistently for the classic consumer).
> Fails with:
> org.opentest4j.AssertionFailedError: Expected
> org.apache.kafka.common.errors.InterruptException to be thrown, but nothing
> was thrown.
> It's been flaky since enabled for the new consumer recently
> [https://ge.apache.org/scans/tests?search.names=Git%20branch&search.rootProjectNames=kafka&search.startTimeMax=1724385599999&search.startTimeMin=1720065600000&search.timeZoneId=America%2FToronto&search.values=trunk&tests.container=org.apache.kafka.clients.consumer.KafkaConsumerTest&tests.test=testPollThrowsInterruptExceptionIfInterrupted(GroupProtocol)%5B2%5D|https://ge.apache.org/scans/tests?search.names=Git%20branch&search.rootProjectNames=kafka&search.startTimeMax=1724385599999&search.startTimeMin=1720065600000&search.timeZoneId=America%2FToronto&search.values=trunk&tests.container=org.apache.kafka.clients.consumer.KafkaConsumerTest&tests.test=testPollThrowsInterruptExceptionIfInterrupted(GroupProtocol)%5B2%5D.]
> Note that a very similar test already exist in AsyncKafkaConsumerTest.
> testPollThrowsInterruptExceptionIfInterrupted, written specifically for the
> async consumer, and that passes consistently.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
