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.
---