Github user hmcl commented on the issue:
https://github.com/apache/storm/pull/1993
@sakanaou I am just about to commit a fix that gives the option to emit or
not emit null tuples as configured in `KafkaSpoutConfig`. The case of non
processable records is already supported if you implement a suitable
[RecordTranslator](https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/RecordTranslator.java)
that has its
[apply](https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/RecordTranslator.java#L39)
method return
[KafkaTuple](https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java)
instances. You can have an instance of `KafkaTuple` that is associated with
the "dead-letter-topic" stream to handle invalid records.
Based on the above, don't think the changes proposed in this pull request
are necessary.
---
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.
---
