Peter Turcsanyi created FLUME-3314:
--------------------------------------
Summary: Flume kafka source/channel throws NPE when
migrateOffsets() is called on nonexistent topics
Key: FLUME-3314
URL: https://issues.apache.org/jira/browse/FLUME-3314
Project: Flume
Issue Type: Bug
Affects Versions: 1.8.0
Reporter: Peter Turcsanyi
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
