[KAFKA-2391] Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout

• Type: Sub-task
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Assignee: Jason Gustafson
• Reporter: Jiangjie Qin
• Created: 31/Jul/15 04:23
• Updated: 30/May/18 15:33
• Resolved: 30/May/18 15:33

Description

The blocking calls should have a timeout from either configuration or parameter. So far we have position(), partitionsFor(), committed() and listTopics().

Issue Links

• blocks: KAFKA-2691 Improve handling of authorization failure during metadata refresh
• is related to: KAFKA-3727 Consumer.poll() stuck in loop on non-existent topic manually assigned
• relates to: KAFKA-3177 Kafka consumer can hang when position() is called on a non-existing partition.
• links to: GitHub Pull Request #283