[
https://issues.apache.org/jira/browse/KAFKA-19613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Uladzislau Blok updated KAFKA-19613:
------------------------------------
Description:
As part of our analysis around KAFKA-19430, we realized it's not possible to
handle a {{CorruptRecordException}} in Streams because it's not exposed to the
client; instead, a generic {{KafkaException}} ** is thrown
The proposed solution is to expose {{CorruptRecordException}} with information
about affected TopicPartition and offset we're trying read from
KIP: https://cwiki.apache.org/confluence/x/NQrxFg
was:
As part of analysis of KAFKA-19430 , we decided it would be useful to expose
root case of consumer request failure (e.g. currently we see just
KafkaException instead of CorruptRecordException)
The idea is to not change public API, but expose root case as a filed of
KafkaException
> Expose consumer CorruptRecordException
> --------------------------------------
>
> Key: KAFKA-19613
> URL: https://issues.apache.org/jira/browse/KAFKA-19613
> Project: Kafka
> Issue Type: Improvement
> Components: clients
> Reporter: Uladzislau Blok
> Assignee: Uladzislau Blok
> Priority: Minor
> Labels: need-kip
> Attachments: corrupted_records.excalidraw.png
>
>
> As part of our analysis around KAFKA-19430, we realized it's not possible to
> handle a {{CorruptRecordException}} in Streams because it's not exposed to
> the client; instead, a generic {{KafkaException}} ** is thrown
> The proposed solution is to expose {{CorruptRecordException}} with
> information about affected TopicPartition and offset we're trying read from
> KIP: https://cwiki.apache.org/confluence/x/NQrxFg
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
