[ 
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)

Reply via email to