[ https://issues.apache.org/jira/browse/KAFKA-6130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jason Gustafson resolved KAFKA-6130. ------------------------------------ Resolution: Fixed Fix Version/s: 1.1.0 > VerifiableConsumer with --max-messages doesn't exit > --------------------------------------------------- > > Key: KAFKA-6130 > URL: https://issues.apache.org/jira/browse/KAFKA-6130 > Project: Kafka > Issue Type: Bug > Reporter: Tom Bentley > Assignee: Tom Bentley > Priority: Minor > Fix For: 1.1.0 > > > If I run {{kafka-verifiable-consumer.sh --max-messages=N}} I expect the tool > to consume N messages and then exit. It will actually consume as many > messages as are in the topic and then block. > The problem is that although the max messages will cause the loop in > onRecordsReceived() to break, the loop in run() will just call > onRecordsReceived() again. -- This message was sent by Atlassian JIRA (v6.4.14#64029)