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