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

    https://github.com/apache/storm/pull/2726#discussion_r200653436
  
    --- Diff: 
external/storm-kafka/src/jvm/org/apache/storm/kafka/ZkCoordinator.java ---
    @@ -107,14 +110,14 @@ public void refresh() {
                             _stormConf,
                             _spoutConfig,
                             id,
    -                        deletedManagers.get(id.partition));
    +                        deletedManagers.get(new 
TopicAndPartition(id.topic, id.partition)));
    --- End diff --
    
    Good point, never mind then.


---

Reply via email to