Paolo Patierno created KAFKA-5434:
-------------------------------------
Summary: 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
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)
