Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-17410

Flaky test testPollThrowsInterruptExceptionIfInterrupted for new consumer

    XMLWordPrintableJSON

Details

    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. 

      Attachments

        Issue Links

          Activity

            People

              frankvicky TengYao Chi
              lianetm Lianet Magrans
              Lianet Magrans Lianet Magrans
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: