[
https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16050917#comment-16050917
]
Paolo Patierno commented on KAFKA-5434:
---------------------------------------
[~vahid] I got your point. Maybe we could have an option as --waiting-partition
(or the opposite --check-partition-exists) in order to have both behaviours.
Wdyt ? Hoping someone else jump into this.
> 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: Paolo Patierno
>
> 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
(v6.4.14#64029)
