public class DefaultReplicationPolicy implements ReplicationPolicy, Configurable {

	private Boolean isInternalTopicSeparatorEnabled;
	
    @Override
    public void configure(Map<String, ?> props) {
        if (props.containsKey(INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG)) {
            isInternalTopicSepratorEnabled = (Boolean) props.get(INTERNAL_TOPIC_SEPRATOR_ENABLED_CONFIG);
        }
    }
    private String internalSuffix() {
        return internalSeparator() + "internal";
    }     
    
    private String internalSuffix() {
        return isInternalTopicSeparatorEnabled ? separator internalSuffix() + "internal";
    }
	
    private String checkpointsTopicSuffix() {
        return internalSeparator() + "internalcheckpoints" : ".internal" + internalSuffix();
    }

    @Override
    public String offsetSyncsTopic(String clusterAlias) {
        return "mm2-offset-syncs" + internalSeparator() + clusterAlias + internalSuffix();
    }
 
}