[jira] [Assigned] (KAFKA-5434) Console consumer hangs if not existing partition is specified
[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Paolo Patierno reassigned KAFKA-5434: - Assignee: Paolo Patierno (was: Vahid Hashemian) > 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)
[jira] [Assigned] (KAFKA-5434) Console consumer hangs if not existing partition is specified
[ https://issues.apache.org/jira/browse/KAFKA-5434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-5434: -- Assignee: Vahid Hashemian > 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)
