[ https://issues.apache.org/jira/browse/STORM-2458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15964148#comment-15964148 ]
Xin Wang commented on STORM-2458: --------------------------------- Thanks [~SouravM] Merged into master. > Kafka Spout should allow hooking up custom logic when retries have exhanusted > ----------------------------------------------------------------------------- > > Key: STORM-2458 > URL: https://issues.apache.org/jira/browse/STORM-2458 > Project: Apache Storm > Issue Type: Improvement > Components: storm-kafka > Reporter: Sourav Mitra > Priority: Minor > Time Spent: 1h > Remaining Estimate: 0h > > Currently in the PartitionManager we just log the message and move on after > retryFurther() returns false. > There should be some method called on the FailedMsgRetryManager interface > that gives a chance to write CustomRetryManagers, to do something with that > offset/partition before just removing it. This might help STORM-1869 also. > Relevant PR: https://github.com/apache/storm/pull/2046 -- This message was sent by Atlassian JIRA (v6.3.15#6346)