uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerHelixManager.java [262:268]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      Set<TopicPartition> topicPartitions = instanceToTopicPartitionsMap.get(instanceId);
      Set<TopicPartition> routeSet = new HashSet<>();
      // TODO: one instance suppose to have only one route
      for (TopicPartition tp : topicPartitions) {
        String topicName = tp.getTopic();
        if (topicName.startsWith(SEPARATOR)) {
          routeSet.add(tp);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/ControllerHelixManager.java [409:415]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      Set<TopicPartition> topicPartitions = instanceToTopicPartitionsMap.get(instanceId);
      Set<TopicPartition> routeSet = new HashSet<>();
      // TODO: one instance suppose to have only one route
      for (TopicPartition tp : topicPartitions) {
        String topicName = tp.getTopic();
        if (topicName.startsWith(SEPARATOR)) {
          routeSet.add(tp);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -