conduktor.io ↗

KIP-1036 — Extend RecordDeserializationException exception

Accepted Kafka 3.8 Consumer

Extends `RecordDeserializationException` to carry the raw key bytes, value bytes, headers, timestamp, and timestamp type of the failed record, plus a `DeserializationExceptionOrigin` enum indicating whether the key or value caused the failure. KIP-334 added offset information to this exception for skip-and-continue semantics, but without access to the raw record bytes, implementing a dead-letter queue or diagnostic logging of poison-pill records requires a separate consumer re-fetch.

Details

AuthorDamien Gasparina
StatusAccepted
Kafka Version3.8
JIRAKAFKA-16507
WikiView on Apache Wiki
Created2024-04-10
Last Modified2024-05-22
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.