[KAFKA-2387] Improve KafkaConsumer API

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: consumer
• Assignee: Unassigned
• Reporter: Jiangjie Qin
• Created: 31/Jul/15 03:41
• Updated: 19/Jul/18 18:39

Description

Currently KafkaConsumer API has several behaviors that are not intuitive or might be a little bit hard to use. This is an umbrella ticket for the improvements of API.

Issue Links

• is required by: KAFKA-1326 New consumer checklist

Sub-Tasks

• subscribe(topic)/unsubscribe(topic) should either take a callback to allow user to handle exceptions or it should be synchronous.: Resolved
• CommitType seems not necessary in commit().: Resolved
• OffsetOutOfRangeException should contain the Offset and Partition info.: Resolved
• Blocking call such as position(), partitionsFor(), committed() and listTopics() should have a timeout: Resolved
• Expose offset commit metadata in new consumer: Resolved
• Expose heartbeat frequency in new consumer configuration: Resolved
• Have KafkaConsumer.committed() return null when there is no committed offset: Resolved
• Expose fetch response high watermark in ConsumerRecords: Open
• Remove Consumer from rebalance callback arguments: Resolved