[ 
https://issues.apache.org/jira/browse/KAFKA-4026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

wxmimperio updated KAFKA-4026:
------------------------------
    Description: 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.  (was: 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 message which in 
buffer.)

> 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)

Reply via email to