[
https://issues.apache.org/jira/browse/STORM-2694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stig Rohde Døssing reassigned STORM-2694:
-----------------------------------------
Assignee: Bijan Fahimi Shemrani
> Create a listener to handle tuple state changes of the KafkaSpout
> -----------------------------------------------------------------
>
> Key: STORM-2694
> URL: https://issues.apache.org/jira/browse/STORM-2694
> Project: Apache Storm
> Issue Type: New Feature
> Components: storm-kafka-client
> Affects Versions: 1.1.1
> Reporter: Bijan Fahimi Shemrani
> Assignee: Bijan Fahimi Shemrani
> Fix For: 2.0.0
>
> Time Spent: 5.5h
> Remaining Estimate: 0h
>
> 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.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
