-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 2.0.0, 1.1.2, 1.0.6, 1.2.1
-
Component/s: storm-kafka-client
-
Labels:
When using a SimpleRecordTranslator 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.