Hello,

How can I add a bolt to TridentTopology?

I realize the use of function on the stream (kafka stream in my case) ...

parsedStream.each(parsedStream.getOutputFields(), new SomeFunction(), new
Fields());

But I want to do subsequent processing by using bolts after the function.

How can I do that?  Tried looking into the API, but appears I need some
help from others who might have tried it already.

Thanks in advance.

Naga

Reply via email to