[FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions This closes #3036.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f266e825 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f266e825 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f266e825 Branch: refs/heads/master Commit: f266e825557f4091094a866e6887f52ca54ff2d7 Parents: 640a149 Author: HungUnicorn <[email protected]> Authored: Mon Jan 9 16:48:24 2017 +0100 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Fri Jan 20 16:33:25 2017 +0100 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f266e825/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java index 29bb8e4..2b816c4 100644 --- a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java +++ b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java @@ -208,6 +208,9 @@ public class FlinkKafkaConsumer09<T> extends FlinkKafkaConsumerBase<T> { if (partitionsForTopic != null) { partitions.addAll(convertToFlinkKafkaTopicPartition(partitionsForTopic)); } + else{ + LOG.info("Unable to retrieve any partitions for the requested topic: {}", topic); + } } }
