[ https://issues.apache.org/jira/browse/KAFKA-17163?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lianet Magrans updated KAFKA-17163: ----------------------------------- 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. was: testSubscriptionOnInvalidTopic expects the consumer throws InvalidTopicException on poll(ZERO), which fails for the new AsyncConsumer. 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. > Revisit testSubscriptionOnInvalidTopic and testPollAuthenticationFailure for > AsyncKafkaConsumer > ----------------------------------------------------------------------------------------------- > > Key: KAFKA-17163 > URL: https://issues.apache.org/jira/browse/KAFKA-17163 > Project: Kafka > Issue Type: Task > Components: consumer > Reporter: Lianet Magrans > Priority: Major > Labels: consumer-threading-refactor > > 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)