[ 
https://issues.apache.org/jira/browse/KAFKA-12906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Sarwar Bhuiyan updated KAFKA-12906:
-----------------------------------
    Description: As documented in KIP-334 (provide link), we should add a new 
RecordDeserializationException, which is raised by the consumer when failing to 
parse a record. This allows the consumer to decide to take an action such as to 
shut down or skip past the record.   (was: When we encounter an exception when 
deserializing it, we raise it to the user and keep the consumer's current 
position at the offset of the failed record. The expectation is that the user 
will either propagate the exception and shutdown or seek past the failed 
record.)

> Consumer should include partition and offset number in deserialization 
> exception
> --------------------------------------------------------------------------------
>
>                 Key: KAFKA-12906
>                 URL: https://issues.apache.org/jira/browse/KAFKA-12906
>             Project: Kafka
>          Issue Type: Improvement
>          Components: consumer
>            Reporter: Sarwar Bhuiyan
>            Assignee: Sarwar Bhuiyan
>            Priority: Minor
>              Labels: kip-334
>
> As documented in KIP-334 (provide link), we should add a new 
> RecordDeserializationException, which is raised by the consumer when failing 
> to parse a record. This allows the consumer to decide to take an action such 
> as to shut down or skip past the record. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to