Sourav Mitra created STORM-2458:
-----------------------------------
Summary: 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
Currently in the PartitionManager we just log the message and move on after
retryFurther() return false.
There should be some method called on the FailedMsgRetryManager interface that
give a chance to write CustomRetryManagers, to do something with that
offset/partition before just removing it. This might help STORM-1869 also.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
