Hi,
I am using Kafka Consumer as a spout while the bolts processes the data.
Since the topology run infinitely waiting for the data to flow by, is there
a way to cleanly exit the topology.
I'd like to know if there is a way to bring down the topology with a clean
exit (meaning, consumer should stop consuming the messages after shutdown
is called, the bolts should finish the jobs being done and finally, the
topology should terminate). terminte can be either via a Ctrl^C, kill from
command line or using the storm jar itself.

Any pointers is appreciated.

Regards,
Kashyap

Reply via email to