warn if topic not found (apache#4834)

vogali · Sep 25, 2017 · 07446ef · 07446ef
1 parent a6470c1
commit 07446ef
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ka-indexing-service/src/main/java/io/druid/indexing/kafka/supervisor/KafkaSupervisor.java b/...ka-indexing-service/src/main/java/io/druid/indexing/kafka/supervisor/KafkaSupervisor.java
@@ -773,6 +773,9 @@ private void updatePartitionDataFromKafka()
     }
 
     List<PartitionInfo> partitions = topics.get(ioConfig.getTopic());
+    if (partitions == null) {
+      log.warn("No such topic [%s] found, list of discovered topics [%s]", ioConfig.getTopic(), topics.keySet());
+    }
     int numPartitions = (partitions != null ? partitions.size() : 0);
 
     log.debug("Found [%d] Kafka partitions for topic [%s]", numPartitions, ioConfig.getTopic());