[
https://issues.apache.org/jira/browse/KAFKA-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15439982#comment-15439982
]
Dru Panchal commented on KAFKA-4026:
------------------------------------
[~imperio]
So far I've tried setting up a 0.8.1.1 environment and used the high level api
to create a consumer. Using the console producer I published a few messages and
as expected they were immediately picked up by my consumer, so I am unable to
reproduce your behavior as described.
Please provide sample code that reproduces your problem along with any
broker/client setting overrides you use.
> 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
> Fix For: 0.8.1.2
>
>
> 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)
