uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/helix/ManagerWorkerHelixHandler.java [152:159]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      return;
    }
    String srcCluster = clustersInfo[1];
    String dstCluster = clustersInfo[2];
    String routeId = message.getPartitionName();

    if (!validateRequest(srcCluster, dstCluster, routeId)) {
      throw new IllegalArgumentException(String.format(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Worker/src/main/java/com/uber/stream/ureplicator/worker/helix/ManagerWorkerHelixHandler.java [232:238]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      return;
    }
    String srcCluster = clustersInfo[1];
    String dstCluster = clustersInfo[2];
    String routeId = message.getPartitionName();
    if (!validateRequest(srcCluster, dstCluster, routeId)) {
      throw new IllegalArgumentException(String.format(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



