Hello, Using the low level API its possible to chain processors like this
builder.addSource("Source", ...); builder.addProcessor("Process1", new MyProcessorSupplier(), "Source"); builder.addProcessor("Process2", new MyProcessorSupplier2(), "Process1"); Can I do something similar with DSL? myStream.map( ...) .process(new MyProcesserSupplier(), "StoreName") .map(...).filter(...) .process(new MyProcesserSupplier2(), "StoreName") .to(topicName) Each process() will do some transformation and do context.forward(...) Srikanth