[GitHub] storm pull request #2755: STORM-3082 Add support to handle absent topics

[aniketalhat]

Github user aniketalhat commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2755#discussion_r200802071
  
    --- 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 --
    
    Not sure what happen here


---