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

[Bijan Fahimi Shemrani (JIRA)]

Bijan Fahimi Shemrani created STORM-2694:
--------------------------------------------

             Summary: 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


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)