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
| Author | Damien Gasparina |
| Status | Accepted |
| Kafka Version | 3.8 |
| JIRA | KAFKA-16507 |
| Wiki | View on Apache Wiki |
| Created | 2024-04-10 |
| Last Modified | 2024-05-22 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.