Tomas Benc commented on KAFKA-4189:

Yes, we're stuck on code, which Edoardo Comar described in comments. But we 
will try to use wakeup() method, hope this helps.

> Consumer poll hangs forever if kafka is disabled
> ------------------------------------------------
>                 Key: KAFKA-4189
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4189
>             Project: Kafka
>          Issue Type: Bug
>          Components: clients, consumer
>    Affects Versions:,
>            Reporter: Tomas Benc
>            Priority: Critical
> We develop web application, where client sends REST request and our 
> application downloads messages from Kafka and sends those messages back to 
> client. In our web application we use "New Consumer API" (not High Level nor 
> Simple Consumer API).
> Problem occurs in case of disabling Kafka and web application is running on. 
> Application receives request and tries to poll messages from Kafka. 
> Processing is on that line blocked until Kafka is enabled.
> ConsumerRecords<byte[], byte[]> records = consumer.poll(1000);
> Timeout parameter of the poll method has no influence in such case. I expect 
> poll method could throw some Exception describing about connection issues.

This message was sent by Atlassian JIRA

Reply via email to