Github user liu-zhaokun commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136286746
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user liu-zhaokun commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136284170
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136283372
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136281189
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user liu-zhaokun commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136279982
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user liu-zhaokun commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136278638
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136238783
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
Github user HeartSaVioR commented on a diff in the pull request:
https://github.com/apache/storm/pull/2297#discussion_r136238719
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicBrokersReader.java
---
@@ -110,7 +110,7 @@ private int getNumPartitions(String
GitHub user liu-zhaokun opened a pull request:
https://github.com/apache/storm/pull/2297
[STORM-2713] when the connection to the first zkserver is
timeout,storm-kafka's kafkaspout will throw a exception
