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)