kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tomas Benc (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-4189) Consumer poll hangs forever if kafka is disabled
Date Sun, 20 Aug 2017 16:45:00 GMT

     [ 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:,
>            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

View raw message