From 51b7ea2e5c61a64006676ccd1622722bb10e6a65 Mon Sep 17 00:00:00 2001
From: jinhong-lu <lu_Jin_hong@163.com>
Date: Mon, 29 Feb 2016 17:32:38 +0800
Subject: [PATCH] add some log

---
 .../src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
index 0fc85b3e34e..f2c3f1a1b51 100644
--- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
+++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
@@ -166,8 +166,9 @@ private int getLeaderFor(String topic, long partition) {
                 throw new RuntimeException("No leader found for partition " + partition);
             }
             return leader;
-        } catch (RuntimeException e) {
-            throw e;
+        } catch (UnsupportedEncodingException e) {
+            LOG.error("Error parsing JSON in the zookeeper because of the Character Encoding is not supported.");
+            throw new RuntimeException(e);
         } catch (Exception e) {
             throw new RuntimeException(e);
         }