[
https://issues.apache.org/jira/browse/KAFKA-5682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-5682:
-----------------------------------
Labels: needs-kip (was: )
> Consumer should include partition in exceptions raised during record
> parsing/validation
> ---------------------------------------------------------------------------------------
>
> Key: KAFKA-5682
> URL: https://issues.apache.org/jira/browse/KAFKA-5682
> Project: Kafka
> Issue Type: Improvement
> Components: consumer
> Reporter: Jason Gustafson
> Labels: needs-kip
> Fix For: 1.0.0
>
>
> When we encounter an exception when validating a fetched record or 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. However, in the latter case, there is no way for the user to know
> which topic partition had the failed record. We should consider exposing an
> exception type to expose this information which users can catch.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
