Hello All,
I am using kafka spout that comes with storm 0.9.3 (
https://github.com/apache/storm).
I am having several different bolts consuming the same tuples from the
spout (in the same topology). These bolts process the tuples and send the
output to different destinations. I have a couple of basic questions:
1) What happens if the destination for some of the bolts is not accessible?
I can have a mechanism in each bolt that returns without consuming any
tuple if the destination is not available. But what happens to the tuples
at hand and when is the next execute is invoked.
     - Do I need to have the destination availability check in a loop?
     - Do I need to keep track of the offset?
2) Is it possible to ack in the bolts.

thanks,
Clay

Reply via email to