catch all errors (apache#3844)

debugger87 · Jan 25, 2017 · b3dae0e · b3dae0e
1 parent 515caa8
commit b3dae0e
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -313,7 +313,7 @@ public void run()
                     try {
                       notice.handle();
                     }
-                    catch (Exception e) {
+                    catch (Throwable e) {
                       log.makeAlert(e, "KafkaSupervisor[%s] failed to handle notice", dataSource)
                          .addData("noticeClass", notice.getClass().getSimpleName())
                          .emit();