Github user HeartSaVioR commented on the issue:
https://github.com/apache/metron/pull/1039
Would you mind if I propose upgrading storm-kafka-client version to 1.2.2?
There's no feature addition on storm-kafka-client but three issues were fixed.
* [STORM-2994](https://issues.apache.org/jira/browse/STORM-2994) -
KafkaSpout consumes messages but doesn't commit offsets
* [STORM-3043](https://issues.apache.org/jira/browse/STORM-3043) -
NullPointerException thrown in SimpleRecordTranslator.apply()
* [STORM-3059](https://issues.apache.org/jira/browse/STORM-3059) -
KafkaSpout throws NPE when hitting a null tuple if the processing guarantee is
not AT_LEAST_ONCE
They're neither blocker nor critical, so the storm-kafka-client module is
on the way to stabilize.
---
