Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2755#discussion_r200803795
--- Diff:
external/storm-kafka/src/jvm/org/apache/storm/kafka/DynamicPartitionConnections.java
---
@@ -57,6 +57,7 @@ public SimpleConsumer register(Partition partition) {
public SimpleConsumer register(Broker host, String topic, int
partition) {
if (!_connections.containsKey(host)) {
+
--- End diff --
Me neither. You can just revert the file and this change should go away.
---
