kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Vahid Hashemian (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-5434) Console consumer hangs if not existing partition is specified
Date Tue, 13 Jun 2017 15:31:00 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048030#comment-16048030

Vahid Hashemian commented on KAFKA-5434:

[~ppatierno] Sure. Feel free to assign the JIRA to yourself.

> Console consumer hangs if not existing partition is specified
> -------------------------------------------------------------
>                 Key: KAFKA-5434
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5434
>             Project: Kafka
>          Issue Type: Bug
>          Components: tools
>            Reporter: Paolo Patierno
>            Assignee: Vahid Hashemian
> Hi,
> if I specify the --partition option for the console consumer with a not existing partition
for a topic, the application hangs indefinitely.
> Debugging the code I see that it asks for metadata but when it receives topic information
and it doesn't find the requested partition inside such metadata, the code retries new time.
> Could be it worst to check if the partition exists using the partitionFor method before
calling the assign in the seek of the BaseConsumer and throwing an exception so printing an
error on the console ?
> Thanks,
> Paolo

This message was sent by Atlassian JIRA

View raw message