KIP-1112 — allow custom processor wrapping
Accepted Kafka 4.0 Streams
Adds a `ProcessorWrapper` interface to Kafka Streams (`StreamsConfig.PROCESSOR_WRAPPER_CLASS_CONFIG`) that allows users to wrap every processor in a topology with a common decorator (logging, tracing, error handling) without modifying each processor individually. Applying cross-cutting concerns to every processor currently requires manual wrapping at every PAPI processor and is completely impossible for DSL-generated processors.
Details
| Author | A. Sophie Blee-Goldman |
| Status | Accepted |
| Kafka Version | 4.0 |
| JIRA | KAFKA-18026 |
| Wiki | View on Apache Wiki |
| Created | 2024-11-16 |
| Last Modified | 2024-11-21 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.