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

    int oldNumPartitions = oldIdealState.getNumPartitions();

    customModeIdealStateBuilder
        .setStateModel(OnlineOfflineStateModel.name)
        .setNumPartitions(oldNumPartitions).setNumReplica(maxNumReplica)
        .setMaxPartitionsPerNode(oldNumPartitions);
    for (String partitionName : oldIdealState.getPartitionSet()) {
      for (String instanceName : oldIdealState.getInstanceStateMap(partitionName).keySet()) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



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

    int oldNumPartitions = oldIdealState.getNumPartitions();

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

    for (String partitionName : oldIdealState.getPartitionSet()) {
      for (String instanceName : oldIdealState.getInstanceStateMap(partitionName).keySet()) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -