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
| Author | Soumyajit Sahu |
| Status | Discussion |
| Wiki | View on Apache Wiki |
| Created | 2021-04-01 |
| Last Modified | 2021-04-14 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.