kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tom Bentley (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-6130) VerifiableConsumer with --max-messages doesn't exit
Date Thu, 26 Oct 2017 10:42:00 GMT

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

Tom Bentley updated KAFKA-6130:
    Summary: VerifiableConsumer with --max-messages doesn't exit  (was: VerifiableConsume
with --max-messages )

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

View raw message