Hi, I'm facing an issue with acknowledgement of tuples. My topology has a spout (BaseRichSpout) that picks a message from RabbitMQ and emits it with the deliveryTag as the message Id. The tuple is then received by a bolt (BaseRichBolt) which processes the tuple. There are other spouts and bolts but not participating in the flow that I'm talking about.
But in the simple case that I tried, the bolt is simply acknowledging the tuple and I'm sure that there are no exceptions in the processing of the tuple in the Bolt but the Spout is receiving a call to fail the tuple. The fail() method is being invoked from backtype.storm.utils.RotatingMap#rotate. The fail is getting called almost immediately. This is happening even if topology.message.timeout.secs is set to 30. Any ideas in troubleshooting is greatly appreciated. What kind of logs will help in troubleshooting? PS: The ACK is working fine on a simplified topology with just one Spout and one Bolt doing. Thanks, Srinath.
