uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicManagementRestletResource.java [119:126]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      if (_managerControllerHelix != null) {
        // federated mode
        Form params = getRequest().getResourceRef().getQueryAsForm();
        String srcCluster = params.getFirstValue("src");
        String dstCluster = params.getFirstValue("dst");
        String routeId = params.getFirstValue("routeid");
        if (srcCluster == null || dstCluster == null || routeId == null) {
          getResponse().setStatus(Status.CLIENT_ERROR_BAD_REQUEST);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Controller/src/main/java/com/uber/stream/kafka/mirrormaker/controller/rest/resources/TopicManagementRestletResource.java [210:217]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    if (_managerControllerHelix != null) {
      // federated mode
      Form params = getRequest().getResourceRef().getQueryAsForm();
      String srcCluster = params.getFirstValue("src");
      String dstCluster = params.getFirstValue("dst");
      String routeId = params.getFirstValue("routeid");
      if (srcCluster == null || dstCluster == null || routeId == null) {
        getResponse().setStatus(Status.CLIENT_ERROR_BAD_REQUEST);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -