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)