[FLUME-3314] Flume kafka source/channel throws NPE when migrateOffsets() is called on nonexistent topics

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.8.0
• Fix Version/s: 1.9.0, 2.0.0
• Assignee: Peter Turcsanyi
• Reporter: Peter Turcsanyi
• Created: 28/Jan/19 11:13
• Updated: 07/Feb/19 14:26
• Resolved: 07/Feb/19 11:41

Description

KafkaConsumer.partitionsFor(topicStr) returns null if the topic does not exist and auto.create.topics.enabled has been set to false on Kafka side.
This case is not handled in the Flume code which leads to NPE.

Null check needs to be added and warning message should be logged instead of the exception stacktrace.