conduktor.io ↗

KIP-729 — Custom validation of records on the broker prior to log append

Discussion Broker

Adds a broker-side plugin interface `RecordInterceptor` (similar to `AuthorizerInterceptor`) that allows custom validation logic to be applied to records before they are appended to the log. There is no mechanism for operators to enforce application-level data quality constraints (e.g., schema compliance) on the broker, forcing consumers to handle malformed records via dead-letter queues or crashes.

Details

AuthorSoumyajit Sahu
StatusDiscussion
WikiView on Apache Wiki
Created2021-04-01
Last Modified2021-04-14
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.