[STORM-3043] NullPointerException thrown in SimpleRecordTranslator.apply()

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0, 1.1.2, 1.0.6, 1.2.1
• 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: Cedric Le Roux
• Reporter: Cedric Le Roux
• Created: 26/Apr/18 17:38
• Updated: 28/Apr/18 11:25
• Resolved: 27/Apr/18 20:07

Description

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.

Issue Links

• links to: GitHub Pull Request #2642
• links to: GitHub Pull Request #2649