Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
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
Note that a very similar test already exist in AsyncKafkaConsumerTest.
testPollThrowsInterruptExceptionIfInterrupted, written specifically for the async consumer, and that passes consistently.
Attachments
Issue Links
- relates to
-
KAFKA-17066 New consumer updateFetchPositions should perform all operations in background thread
- Resolved
- links to