conduktor.io ↗

KIP-334 — Include partitions in exceptions raised during consumer record deserialization/validation

Accepted Consumer

KIP-334 introduces a `RecordDeserializationException` subclass of `SerializationException` that carries the `TopicPartition` and `offset` of the record that caused the deserialization failure. Previously, the exception message embedded the partition and offset as a string, making it impossible for error-handling code to programmatically seek past the faulty record without fragile message parsing.

Details

AuthorStanislav Kozlovski
StatusAccepted
JIRAKAFKA-5682
WikiView on Apache Wiki
Created2018-07-05
Last Modified2021-06-03
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.