Repository: flink Updated Branches: refs/heads/release-1.2 5cbaf796d -> 694927634
[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/69492763 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/69492763 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/69492763 Branch: refs/heads/release-1.2 Commit: 69492763444a9cc5efb1e26e2864abce71787211 Parents: 5cbaf79 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:51:54 2017 +0100 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/69492763/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); + } } }
