From f053d9b68c20df8e41f6bcf0348b26d413503fe1 Mon Sep 17 00:00:00 2001
From: "R. Tyler Croy" <tyler@monkeypox.org>
Date: Sun, 22 Mar 2015 11:08:40 -0700
Subject: [PATCH] Catch and log exceptions coming from the dumpMetadata() call

Fixes #23
---
 .../com/github/lookout/verspaetung/KafkaPoller.groovy      | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy b/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy
index d74e7a7..0465404 100644
--- a/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy
+++ b/src/main/groovy/com/github/lookout/verspaetung/KafkaPoller.groovy
@@ -55,7 +55,12 @@ class KafkaPoller extends Thread {
              * topics that we should keep an eye on
              */
             if (this.currentTopics.size() > 0) {
-                dumpMetadata()
+                try {
+                    dumpMetadata()
+                }
+                catch (Exception ex) {
+                    logger.error("Failed to fetch and dump Kafka metadata", ex)
+                }
             }
 
             Thread.sleep(POLLER_DELAY)