void syncTopicConfigs()
            throws InterruptedException, ExecutionException {
        boolean incremental = useIncrementalAlterConfigs;
        Map<String, Config> sourceConfigs = describeTopicConfigs(topicsBeingReplicated());
        Map<String, Config> targetConfigs = sourceConfigs.entrySet().stream()
            .collect(Collectors.toMap(x -> formatRemoteTopic(x.getKey()), x -> targetConfig(x.getValue(), incremental)));
        if (incremental) {
            incrementalAlterConfigs(targetConfigs);
        } else {
            deprecatedAlterConfigs(targetConfigs);
        }
    }
Replicate data, configuration, and ACLs between clusters.

 @see MirrorSourceConfig for supported config properties.
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java