You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ewen Cheslack-Postava (JIRA)" <ji...@apache.org> on 2017/01/26 03:44:26 UTC
[jira] [Resolved] (KAFKA-4026) consumer block
[ https://issues.apache.org/jira/browse/KAFKA-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ewen Cheslack-Postava resolved KAFKA-4026.
------------------------------------------
Resolution: Not A Problem
Assignee: Ewen Cheslack-Postava
Fix Version/s: (was: 0.8.1.2)
[~imperio] For the old, high-level consumer, there is a configuration parameter consumer.timeout.ms that you can use to control how long the consumer blocks waiting for new messages.
That said, we'd recommend moving to the new consumer if possible (which I realize might not be an option given the version you are on). It has a different API based on single-threaded polling for data -- in that API the timeout is explicit since it is provided to every poll() API call.
(I'm resolving this as it seemed to just be a question, and removed the fix version.)
> consumer block
> --------------
>
> Key: KAFKA-4026
> URL: https://issues.apache.org/jira/browse/KAFKA-4026
> Project: Kafka
> Issue Type: Test
> Components: consumer
> Affects Versions: 0.8.1.1
> Environment: ubuntu 14.04
> Reporter: wxmimperio
> Assignee: Ewen Cheslack-Postava
>
> when i use high level api make consumer. it is a block consumer,how can i know the time of blocked?I put messages into a buffer.It did not reach the buffer length the consumer blocked,the buffer can not be handled.How can i deal with this problem?The buffer did not reach the buffer length,I can handled the buffer.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)