[ https://issues.apache.org/jira/browse/FLUME-3314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16762708#comment-16762708 ]
Hudson commented on FLUME-3314: ------------------------------- SUCCESS: Integrated in Jenkins build flume-trunk #757 (See [https://builds.apache.org/job/flume-trunk/757/]) FLUME-3314 Fixed NPE in Kafka source/channel during offset migration (szaboferee: [http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=606eabb09997fa939735b5600f526a99895c350c]) * (edit) flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/TestKafkaSource.java * (edit) flume-ng-channels/flume-kafka-channel/pom.xml * (edit) flume-ng-sources/flume-kafka-source/pom.xml * (edit) flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java * (edit) flume-ng-sinks/flume-ng-kafka-sink/src/test/resources/kafka-server.properties * (edit) flume-ng-channels/flume-kafka-channel/src/test/resources/kafka-server.properties * (edit) flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java * (edit) flume-ng-sources/flume-kafka-source/src/test/java/org/apache/flume/source/kafka/KafkaSourceEmbeddedKafka.java * (edit) flume-ng-channels/flume-kafka-channel/src/test/java/org/apache/flume/channel/kafka/TestOffsetsAndMigration.java > 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 > Assignee: Peter Turcsanyi > Priority: Minor > Fix For: 1.9.0, 2.0.0 > > > 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-unsubscr...@flume.apache.org For additional commands, e-mail: issues-h...@flume.apache.org