Thanks Sophie! This KIP will certainly make it easier to implement any kind of custom functionality across all processors in the DSL, I can imagine quite a few use cases for this.
One suggestion, we should consider including a configure() method that takes in Map<String, ?> configs, so that it can be configured based on things like application.id (e.g. for emitting custom metrics per processor). - Almog On Fri, Nov 15, 2024 at 10:16 PM Sophie Blee-Goldman <sop...@responsive.dev> wrote: > Hey all, > > We have a short KIP we'd like to propose which will allow injecting custom > code modules around the processors of Kafka Streams applications, including > DSL-built topologies. > > Please let us know if you have any thoughts or concerns > > <goog_579523372> > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-1112%3A+allow+custom+processor+wrapping > > Cheers, > Sophie >
