From 2df9bdecdc2fd4aad8527e1c0c4c5cbe1c8c8e35 Mon Sep 17 00:00:00 2001
From: Parag Jain <paragjain16@gmail.com>
Date: Sun, 24 Sep 2017 22:21:46 -0500
Subject: [PATCH] warn if topic not found (#4834)

---
 .../io/druid/indexing/kafka/supervisor/KafkaSupervisor.java    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/supervisor/KafkaSupervisor.java b/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/supervisor/KafkaSupervisor.java
index f2065e1a4c80..a62e9fd826b7 100644
--- a/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/supervisor/KafkaSupervisor.java
+++ b/extensions-core/kafka-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());