[KAFKA-5858] consumer.poll() shouldn't throw exception due to deserialization error

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.11.0.0
• Assignee: Unassigned
• Reporter: Jun Rao
• Created: 08/Sep/17 00:11
• Updated: 08/Sep/17 02:02
• Resolved: 08/Sep/17 02:02

Description

Currently, the new consumer will throw an exception in poll() if it hits a deserialization error. The consumer then can't make progress from this point on. It will be better to throw the deserialization exception only when the key/value of the ConsumerRecord is accessed, like the old consumer does.