@Ambud Sharma we are testing this change and will accept once we are done. I am still not 100% convinced that this solves the problem since the Storm documentation says BasicBolt does the acking and anchoring http://storm.apache.org/releases/1.0.1/Guaranteeing-message-processing.html Search for BasicBolt in that link and you will find "Storm has an interface called BasicBolt that encapsulates this pattern for you." ... View more