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