GitHub user sakanaou opened a pull request:
https://github.com/apache/storm/pull/1993
STORM-2402: KafkaSpout sub-classes should be able to customize tuple
processing
We need a `KafkaSpout` that writes unprocessable records to a
"dead-letter-topic". For this to function we sub-classed `KafkaSpout` and added
the corresponding code. Without this patch sub-classses can not have access to
the actual tuples/records but just the `KafkaSpoutMessageId` in `ack()` and
`fail()`.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/sakanaou/storm STORM-2402
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1993.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1993
----
commit a3460d6980f1746262e93053ffa61173a3af6996
Author: sakanaou <[email protected]>
Date: 2017-03-09T15:25:20Z
STORM-2402: Allow subclasses of KafkaSpout to react on emitted records
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
