[
https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16048035#comment-16048035
]
Paolo Patierno commented on KAFKA-5434:
---------------------------------------
[~vahid] I can't do that now :(
I asked for being added to the contributors list but I'm not part of it yet.
Thanks
Paolo
> 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
(v6.4.14#64029)
