Hi,
All of my bolts in the topology implement BaseRichBolt and following is the
signature of prepare method, and I do not pass the input tuple as an argument
in the collector.emit of any of the bolts execute implementation. So,
essentially am not anchoring the tuples.
Since I am not anchoring the tuples and using BaseRichBolt, what happens with
collector.ack ? Documentation says BaseRichBolt does not implicitly anchor or
ack the tuples.
What is the behaviour of collector.ack, also can you point me to the
implementation of collector.ack?
@Override
public final void prepare(@SuppressWarnings("rawtypes") Map stormConf,
TopologyContext context, OutputCollector collector) {
