Hi all, According to the link : https://storm.incubator.apache.org/documentation/Guaranteeing-message-processing.html ,
A tuple is considered failed, if it fails to be processed within the Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS <https://storm.incubator.apache.org/apidocs/backtype/storm/Config.html#TOPOLOGY_MESSAGE_TIMEOUT_SECS> configuration that defaults to 30 seconds. I have made my tuple processing in the Bolt to be slower than 30 secs (using Thread.sleep ) But, the Spout's "fail" method never gets invoked. Also, I have used anchored emits in the Spout using : collector.emit(new Values(emitWord), msgId); The Bolt thread is waking up from sleep in 60 secs , but, the Spout's fail method never gets invoked. What am I missing ? Thanks -Binita
