[FLUME-3064] NullPointerException when communication issue with kafka server

• Type: Bug
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Affects Version/s: 1.7.0
• Component/s: Kafka Channel, Sinks+Sources

Environment

logging level must be DEBUG

• Flags: Patch
• Assignee: Unassigned
• Reporter: Laszlo Hornyak
• Created: 01/Mar/17 18:36
• Updated: 07/Mar/17 19:08

Description

When flume has communication issues with kafka and the logging level is set to DEBUG, additionally to the log of the communication error an NPE will be thrown. This happens because kafka callback metadata parameter can be null, this is not handled, but it is only evaluated if the log level is DEBUG.

The problem affects the kafka source and the channel.

Issue Links

• links to: GitHub Pull Request #111