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:

org.apache.kafka.common.Configurable, ReplicationPolicy

public class IdentityReplicationPolicy
extends DefaultReplicationPolicy

Alternative implementation of ReplicationPolicy that does not rename remote topics. This is useful for migrating from legacy MirrorMaker, or for any use-case involving one-way replication.

N.B. MirrorMaker is not able to prevent cycles when using this replication policy, so take care that your replication topology is acyclic. If migrating from legacy MirrorMaker, 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)
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

equals, 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)

Specified by:

configure in interface org.apache.kafka.common.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.formatRemoteTopic(String, String).

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, this method will return that.

In the special case of heartbeats, we defer to DefaultReplicationPolicy.topicSource(String).

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.upstreamTopic(String).

Specified by:

upstreamTopic in interface ReplicationPolicy

Overrides:

upstreamTopic in class DefaultReplicationPolicy