[STORM-1086] Make FailedMsgRetryManager configurable when setting up KafkaSpout

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 2.0.0, 1.0.2, 1.1.0
• Component/s: storm-kafka
• Labels: pull-request-available
• Assignee: Abhishek Agarwal
• Reporter: Nick Kleinschmidt
• Created: 02/Oct/15 17:22
• Updated: 24/May/18 15:16
• Resolved: 19/Jul/16 09:27

Description

The FailedMsgRetryManager interface makes replay behavior configurable and we default to using ExponentialBackoffMsgRetryManager, but there's no way to define your own FailedMsgRetryManager and plug it in when setting up KafkaSpout.

Issue Links

• links to: GitHub Pull Request #780