flume-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Peter Turcsanyi (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLUME-3314) Flume kafka source/channel throws NPE when migrateOffsets() is called on nonexistent topics
Date Mon, 28 Jan 2019 11:14:00 GMT
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


Mime
View raw message