[
https://issues.apache.org/jira/browse/KAFKA-4189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tomas Benc resolved KAFKA-4189.
-------------------------------
Resolution: Not A Problem
Kafka API contains wakeup() method for such situation. It requires little bit
more work - we have to monitor kafka consumer in separate thread, and then call
wakeup() from that thread.
> 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: 0.9.0.1, 0.10.0.1
> 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
(v6.4.14#64029)
