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

["Stig Rohde Døssing (JIRA)" <ji...@apache.org>]

     [ 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)