Hi, Just need a confirmation for this topology:
*Spout* ---emit---> *Bolt1* ---emit---> *Bolt2* Spout is BaseRichSpout. Bolt1 and Bolt2 are BaseRichBolt. Spout emits just one tuple per nextTuple() call. Bolt1 anchors to the tuple it received from Spout and emits many different tuple objects. If any of the emits of Bolt1 fails, is there no way for Bolt 1 to re-emit the tuple? Do I have to wait for the topology to figure out that one of Bolt1's tuples failed and then do a re-emit from the Spout? -- Regards, Navin
