org.apache.kafka.connect.mirror

Class IdentityReplicationPolicy

java.lang.Object

org.apache.kafka.connect.mirror.DefaultReplicationPolicy

org.apache.kafka.connect.mirror.IdentityReplicationPolicy

All Implemented Interfaces:

Configurable, ReplicationPolicy

public class IdentityReplicationPolicy
extends DefaultReplicationPolicy

IdentityReplicationPolicy does not rename remote topics. This is useful for migrating from legacy MM1, or for any use-case involving one-way replication.

N.B. MirrorMaker is not able to prevent cycles when using this class, so take care that your replication topology is acyclic. If migrating from MirrorMaker v1, this will likely already be the case.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SOURCE_CLUSTER_ALIAS_CONFIG

Fields inherited from class org.apache.kafka.connect.mirror.DefaultReplicationPolicy

INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG, INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT, SEPARATOR_CONFIG, SEPARATOR_DEFAULT

Constructor Summary

Constructors

Constructor and Description
IdentityReplicationPolicy()

Method Summary

Modifier and Type	Method and Description
void	configure(Map<String,?> props) Configure this class with the given key-value pairs
String	formatRemoteTopic(String sourceClusterAlias, String topic) Unlike DefaultReplicationPolicy, IdentityReplicationPolicy does not include the source cluster alias in the remote topic name.
String	topicSource(String topic) Unlike DefaultReplicationPolicy, IdentityReplicationPolicy cannot know the source of a remote topic based on its name alone.
String	upstreamTopic(String topic) Since any topic may be a "remote topic", this just returns `topic`.

Methods inherited from class org.apache.kafka.connect.mirror.DefaultReplicationPolicy

checkpointsTopic, isCheckpointsTopic, isMM2InternalTopic, offsetSyncsTopic

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.connect.mirror.ReplicationPolicy

heartbeatsTopic, isHeartbeatsTopic, isInternalTopic, originalTopic

Field Detail

SOURCE_CLUSTER_ALIAS_CONFIG

public static final String SOURCE_CLUSTER_ALIAS_CONFIG

See Also:

Constant Field Values

Constructor Detail

IdentityReplicationPolicy

public IdentityReplicationPolicy()

Method Detail

configure

public void configure(Map<String,?> props)

Description copied from interface: Configurable

Configure this class with the given key-value pairs

Specified by:

configure in interface Configurable

Overrides:

configure in class DefaultReplicationPolicy

formatRemoteTopic

public String formatRemoteTopic(String sourceClusterAlias,
                                String topic)

Unlike DefaultReplicationPolicy, IdentityReplicationPolicy does not include the source cluster alias in the remote topic name. Instead, topic names are unchanged.

In the special case of heartbeats, we defer to DefaultReplicationPolicy.

Specified by:

formatRemoteTopic in interface ReplicationPolicy

Overrides:

formatRemoteTopic in class DefaultReplicationPolicy

topicSource

public String topicSource(String topic)

Unlike DefaultReplicationPolicy, IdentityReplicationPolicy cannot know the source of a remote topic based on its name alone. If `source.cluster.alias` is provided, `topicSource` will return that.

In the special case of heartbeats, we defer to DefaultReplicationPolicy.

Specified by:

topicSource in interface ReplicationPolicy

Overrides:

topicSource in class DefaultReplicationPolicy

upstreamTopic

public String upstreamTopic(String topic)

Since any topic may be a "remote topic", this just returns `topic`.

In the special case of heartbeats, we defer to DefaultReplicationPolicy.

Specified by:

upstreamTopic in interface ReplicationPolicy

Overrides:

upstreamTopic in class DefaultReplicationPolicy