uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/IdealStateBuilder.java [68:78]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    final CustomModeISBuilder customModeIdealStateBuilder = new CustomModeISBuilder(topicName);

    int oldNumPartitions = oldIdealState.getNumPartitions();

    customModeIdealStateBuilder
        .setStateModel(OnlineOfflineStateModel.name)
        .setNumPartitions(oldNumPartitions).setNumReplica(1)
        .setMaxPartitionsPerNode(oldNumPartitions);

    for (String partitionName : oldIdealState.getPartitionSet()) {
      String instanceName = oldIdealState.getInstanceStateMap(partitionName).keySet().iterator().next();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uReplicator-Manager/src/main/java/com/uber/stream/kafka/mirrormaker/manager/core/IdealStateBuilder.java [109:119]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    final CustomModeISBuilder customModeIdealStateBuilder = new CustomModeISBuilder(topicName);

    int oldNumPartitions = oldIdealState.getNumPartitions();

    customModeIdealStateBuilder
        .setStateModel(OnlineOfflineStateModel.name)
        .setNumPartitions(oldNumPartitions).setNumReplica(1)
        .setMaxPartitionsPerNode(oldNumPartitions);

    for (String partitionName : oldIdealState.getPartitionSet()) {
      String instanceName = oldIdealState.getInstanceStateMap(partitionName).keySet().iterator().next();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -