Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-16823 Extract LegacyConsumer-specific unit tests from generic KafkaConsumerTest
  3. KAFKA-17163

Revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure for AsyncKafkaConsumer

    XMLWordPrintableJSON

Details

    Description

      testSubscriptionOnInvalidTopic expects the consumer throws
      InvalidTopicException on poll(ZERO), which fails for the new AsyncConsumer (same for testPollAuthenticationFailure). We should investigate if this needs the same fix applied to other tests, to do continuous poll(ZERO) to allow for the background thread to run after a fetch event has been added in the app thread, so that related errors can be propagated in poll. See linked Jira with similar fix. 

      Attachments

        Issue Links

          relates to

          Sub-task - The sub-task of the issue KAFKA-17132 Revisit testMissingOffsetNoResetPolicy for AsyncConsumer

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #16638

          Activity

            People

              taijuwu TaiJuWu
              lianetm Lianet Magrans
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: