@@ -0,0 +1,1121 @@
+package com.salesforce.storm.spout.sideline.kafka.failedMsgRetryManagers;%0A%0Aimport com.salesforce.storm.spout.sideline.TupleMessageId;%0A%0Aimport java.util.Map;%0Aimport java.util.Set;%0A%0A/**%0A * Never retry failed messages.%0A */%0Apublic class NoRetryFailedMsgRetryManager implements FailedMsgRetryManager %7B%0A    @Override%0A    public void prepare(Map stormConfig) %7B%0A        // Nothing to do%0A    %7D%0A%0A    @Override%0A    public void failed(TupleMessageId messageId) %7B%0A        // Nothing to do%0A    %7D%0A%0A    @Override%0A    public void acked(TupleMessageId messageId) %7B%0A        // Nothing to do%0A    %7D%0A%0A    @Override%0A    public void retryStarted(TupleMessageId messageId) %7B%0A        // Nothing to do%0A    %7D%0A%0A    @Override%0A    public TupleMessageId nextFailedMessageToRetry() %7B%0A        return null;%0A    %7D%0A%0A    @Override%0A    public boolean shouldReEmitMsg(TupleMessageId messageId) %7B%0A        // Never re-emit%0A        return false;%0A    %7D%0A%0A    @Override%0A    public boolean retryFurther(Long offset) %7B%0A        return false;%0A    %7D%0A%0A    @Override%0A    public Set%3CTupleMessageId%3E clearOffsetsBefore(TupleMessageId messageId) %7B%0A        return null;%0A    %7D%0A%7D%0A

Add FailedMsgRetryManager that never retries failed tuples.