Cedric Le Roux created STORM-3043:
-------------------------------------
Summary: NullPointerException thrown in
SimpleRecordTranslator.apply()
Key: STORM-3043
URL: https://issues.apache.org/jira/browse/STORM-3043
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka-client
Reporter: Cedric Le Roux
When using a SimpleRecordTranslator (or ByTopicRecordTranslator which extends
it) with a user-defined translator Func, a NullPointerException will be thrown
if Func.apply() returns null. A null List object is a valid return value from
apply() if the ConsumerRecord is invalid.
SimpleRecordTranslator does not check for a null result before attempting to
call the addAll method of the List.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
