[STORM-3059] KafkaSpout throws NPE when hitting a null tuple if the processing guarantee is not AT_LEAST_ONCE

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0, 1.1.3, 1.0.7, 1.2.2
• Fix Version/s: 2.0.0, 1.1.3, 1.0.7, 1.2.2
• Component/s: storm-kafka-client
• Labels: pull-request-available
• Assignee: Stig Rohde Døssing
• Reporter: Stig Rohde Døssing
• Created: 06/May/18 07:46
• Updated: 07/May/18 13:10
• Resolved: 07/May/18 13:10

Description

Introduced with STORM-2994

java.lang.NullPointerException: null
at org.apache.storm.kafka.spout.KafkaSpout.emitOrRetryTuple(KafkaSpout.java:507)
~[stormjar.jar:?]
at org.apache.storm.kafka.spout.KafkaSpout.emitIfWaitingNotEmitted(KafkaSpout.java:440)
~[stormjar.jar:?]
at org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:308)
~[stormjar.jar:?]

Issue Links

• links to: GitHub Pull Request #2662
• links to: GitHub Pull Request #2663