wxmimperio created KAFKA-4026:
---------------------------------

             Summary: 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 situation?The buffer did not reach the buffer length,I can handled the 
message which in buffer.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to