Migrate Kafka Using the MigratingReplicationPolicy

package com.cloudera.dim.mirror;
import java.util.Map;
import org.apache.kafka.common.Configurable;
import org.apache.kafka.connect.mirror.ReplicationPolicy;
import org.apache.kafka.connect.mirror.MirrorConnectorConfig;
 
public class MigratingReplicationPolicy implements ReplicationPolicy, Configurable {
    private String sourceClusterAlias;
 
    @Override
    public void configure(Map<String, ?> props) {
        // The source cluster alias cannot be determined just by looking at the prefix of the remote topic name.
        // We extract this info from the configuration.
        sourceClusterAlias = (String) props.get(MirrorConnectorConfig.SOURCE_CLUSTER_ALIAS);
    }
 
    @Override
    public String formatRemoteTopic(String sourceClusterAlias, String topic) {
        // We do not apply any prefix.
        return topic;
    }
 
    @Override
    public String topicSource(String topic) {
        // return from config
        return sourceClusterAlias;
    }
 
    @Override
    public String upstreamTopic(String topic) {
        return null;
    }
}

srm-control topics --source [SOURCE_CLUSTER] --target [TARGET_CLUSTER] --add ".*"

srm-control groups --source [SOURCE_CLUSTER] --target [TARGET_CLUSTER] --add ".*"

The HDF instances of Kafka and Streams Messaging Manager are no longer required.