[KAFKA-6608] Add TimeoutException to KafkaConsumer#position()

• Type: Improvement
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Component/s: consumer
• Labels: kip
• Flags: Important
• Assignee: Richard Yu
• Reporter: Richard Yu
• Created: 03/Mar/18 18:11
• Updated: 16/Nov/23 01:01
• Resolved: 30/May/18 15:30

Description

In KAFKA-4879, Kafka Consumer hangs indefinitely due to Fetcher's timeout being set to Long.MAX_VALUE. While fixing this issue, it was pointed out that if a timeout was added to methods which commits offsets synchronously, a stricter control on time could be achieved.

https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75974886

Issue Links

• blocks: SPARK-18057 Update structured streaming kafka from 0.10.0.1 to 2.0.0
• is part of: KAFKA-4879 KafkaConsumer.position may hang forever when deleting a topic
• is related to: KAFKA-7941 Connect KafkaBasedLog work thread terminates when getting offsets fails because broker is unavailable
• relates to: KAFKA-15837 Throw error on use of Consumer.poll(long timeout)
• links to: GitHub Pull Request #4643
• links to: GitHub Pull Request #5014
• mentioned in: Page Loading...
• mentioned in: Page Loading...