I have a main bolt B1 listening to spout S1. Once processing is done on B1 it emits message to B2, B3, B4 ad B5. After B5 process the data, it then emits this message to B6, B7and B8. In the process if B3 fails to process the data, then does the failed acknowledgement gets acked all the way back to the spout? Or if B3 fails, the message will just get re-emitted from bolt B1?
In this case the message it going to get read twice and the data is duplicated. How do I prevent this to happen. We are using KafkaSpout that came in with storm.0.9.2. Is implementing trident method gonna help resolve this issue? Thanks. -- Kushan Maskey 817.403.7500 M. Miller & Associates <http://mmillerassociates.com/> [email protected]
