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);
+                               }
                        }
                }
 

Reply via email to