From eb8e1b0a979bccc10f78817b5374af125944b583 Mon Sep 17 00:00:00 2001
From: Parag Jain <paragjain16@gmail.com>
Date: Mon, 8 May 2017 17:05:25 -0500
Subject: [PATCH] Prevent interrupted exception from polluting log during
 supervisor shutdown (#4253)

* Prevent interrupted exception from polluting log during supervisor shutdown

* do nothing in case of InterruptedException
---
 .../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 91deb18a161..44bdb541cee 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
@@ -1794,6 +1794,9 @@ public class KafkaSupervisor implements Supervisor
               ServiceMetricEvent.builder().setDimension("dataSource", dataSource).build("ingest/kafka/lag", lag)
           );
         }
+        catch (InterruptedException e) {
+          // do nothing, probably we are shutting down
+        }
         catch (Exception e) {
           log.warn(e, "Unable to compute Kafka lag");
         }