conduktor.io ↗

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

AuthorA. Sophie Blee-Goldman
StatusAccepted
Kafka Version4.0
JIRAKAFKA-18026
WikiView on Apache Wiki
Created2024-11-16
Last Modified2024-11-21
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.