[KAFKA-5434] Console consumer hangs if not existing partition is specified

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Won't Do
• Component/s: tools
• Assignee: Paolo Patierno
• Reporter: Paolo Patierno
• Created: 12/Jun/17 16:11
• Updated: 06/Jun/18 06:34
• Resolved: 06/Jun/18 06:34

Description

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

Issue Links

• links to: GitHub Pull Request #3335
• links to: GitHub Pull Request #3335