[STORM-2458] Kafka Spout should allow hooking up custom logic when retries have exhanusted

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.0.0
• Component/s: storm-kafka
• Assignee: Unassigned
• Reporter: Sourav Mitra
• Created: 06/Apr/17 11:49
• Updated: 11/Apr/17 10:29
• Resolved: 11/Apr/17 10:29

Description

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

Issue Links

• links to: GitHub Pull Request #2046