[KAFKA-17410] Flaky test testPollThrowsInterruptExceptionIfInterrupted for new consumer

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Component/s: clients, consumer
• Labels: consumer-threading-refactor flaky-test
• Assignee: TengYao Chi
• Reporter: Lianet Magrans
• Reviewer: Lianet Magrans
• Created: 22/Aug/24 22:10
• Updated: 12/Sep/24 10:41
• Resolved: 12/Sep/24 10:41

Description

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

Note that a very similar test already exist in AsyncKafkaConsumerTest.
testPollThrowsInterruptExceptionIfInterrupted, written specifically for the async consumer, and that passes consistently. 

Issue Links

• relates to: KAFKA-17066 New consumer updateFetchPositions should perform all operations in background thread
• links to: GitHub Pull Request #17172