[STORM-2694] Create a listener to handle tuple state changes of the KafkaSpout

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.1.1
• Fix Version/s: 2.0.0, 1.2.0
• Component/s: storm-kafka-client
• Assignee: Bijan Fahimi Shemrani
• Reporter: Bijan Fahimi Shemrani
• Created: 17/Aug/17 19:31
• Updated: 30/Aug/17 15:23
• Resolved: 29/Aug/17 19:38

Description

We had a couple of use cases where we needed the KafkaSpout to put failed tuples into a dead letter queue.

The pull request proposes a listener which is called every time a tuple in the KafkaSpout is emitted/acked/failed/retried.

Issue Links

• links to: GitHub Pull Request #2282
• links to: GitHub Pull Request #2298