You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Uladzislau Blok (Jira)" <ji...@apache.org> on 2025/09/10 17:16:00 UTC

[jira] [Updated] (KAFKA-19613) Expose consumer CorruptRecordException

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

Uladzislau Blok updated KAFKA-19613:
------------------------------------
    Summary: Expose consumer CorruptRecordException  (was: Expose consumer CorruptRecordException as case 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 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



--
This message was sent by Atlassian Jira
(v8.20.10#820010)