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

["Peter Turcsanyi (JIRA)" <ji...@apache.org>]

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: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org