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

Reply via email to