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

["Bijan Fahimi Shemrani (JIRA)" <ji...@apache.org>]

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)