Is there a way to replay batches using IBatchSpout? The interface has an ack method, which is called whenever a batch is finished processing. However, there isn't a fail method similar to BaseRichSpout, which allows you to replay tuples.
Looking at the FixedBatchSpout [1] example, the emitBatch function checks to see if the batch for a specific batch ID is already present. This seems to imply that the emitBatch function will be called if a certain batch is failed. But, testing shows that the failed batches are never replayed. [1] https://github.com/apache/storm/blob/master/storm-core/src/jvm/storm/trident/testing/FixedBatchSpout.java
