Package org.apache.kafka.connect.mirror

Class DefaultReplicationPolicy

java.lang.Object

org.apache.kafka.connect.mirror.DefaultReplicationPolicy

All Implemented Interfaces:

Configurable, ReplicationPolicy

Direct Known Subclasses:

IdentityReplicationPolicy

public class DefaultReplicationPolicy
extends Object
implements ReplicationPolicy, Configurable

Defines remote topics like "us-west.topic1". The separator is customizable and defaults to a period.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG
static final Boolean	INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT
static final String	SEPARATOR_CONFIG
static final String	SEPARATOR_DEFAULT

Constructor Summary

Constructors

Constructor	Description
DefaultReplicationPolicy()

Method Summary

Modifier and Type	Method	Description
String	checkpointsTopic(String clusterAlias)	Returns the name checkpoint topic for given cluster alias.
void	configure(Map<String,?> props)	Configure this class with the given key-value pairs
String	formatRemoteTopic(String sourceClusterAlias, String topic)	How to rename remote topics; generally should be like us-west.topic1.
boolean	isCheckpointsTopic(String topic)	check if topic is a checkpoint topic.
boolean	isMM2InternalTopic(String topic)	Check topic is one of MM2 internal topic, this is used to make sure the topic doesn't need to be replicated.
String	offsetSyncsTopic(String clusterAlias)	Returns the offset-syncs topic for given cluster alias.
String	topicSource(String topic)	Source cluster alias of given remote topic, e.g.
String	upstreamTopic(String topic)	Name of topic on the source cluster, e.g.

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 Details

SEPARATOR_CONFIG

public static final String SEPARATOR_CONFIG

See Also:

• Constant Field Values

SEPARATOR_DEFAULT

public static final String SEPARATOR_DEFAULT

See Also:

• Constant Field Values

INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG

public static final String INTERNAL_TOPIC_SEPARATOR_ENABLED_CONFIG

See Also:

• Constant Field Values

INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT

public static final Boolean INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT

Constructor Details

DefaultReplicationPolicy

public DefaultReplicationPolicy()

Method Details

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

formatRemoteTopic

public String formatRemoteTopic(String sourceClusterAlias,
 String topic)

Description copied from interface: ReplicationPolicy

How to rename remote topics; generally should be like us-west.topic1.

Specified by:

formatRemoteTopic in interface ReplicationPolicy

topicSource

public String topicSource(String topic)

Description copied from interface: ReplicationPolicy

Source cluster alias of given remote topic, e.g. "us-west" for "us-west.topic1". Returns null if not a remote topic.

Specified by:

topicSource in interface ReplicationPolicy

upstreamTopic

public String upstreamTopic(String topic)

Description copied from interface: ReplicationPolicy

Name of topic on the source cluster, e.g. "topic1" for "us-west.topic1".

Topics may be replicated multiple hops, so the immediately upstream topic may itself be a remote topic.

Returns null if not a remote topic.

Specified by:

upstreamTopic in interface ReplicationPolicy

offsetSyncsTopic

public String offsetSyncsTopic(String clusterAlias)

Description copied from interface: ReplicationPolicy

Returns the offset-syncs topic for given cluster alias.

Specified by:

offsetSyncsTopic in interface ReplicationPolicy

checkpointsTopic

public String checkpointsTopic(String clusterAlias)

Description copied from interface: ReplicationPolicy

Returns the name checkpoint topic for given cluster alias.

Specified by:

checkpointsTopic in interface ReplicationPolicy

isCheckpointsTopic

public boolean isCheckpointsTopic(String topic)

Description copied from interface: ReplicationPolicy

check if topic is a checkpoint topic.

Specified by:

isCheckpointsTopic in interface ReplicationPolicy

isMM2InternalTopic

public boolean isMM2InternalTopic(String topic)

Description copied from interface: ReplicationPolicy

Check topic is one of MM2 internal topic, this is used to make sure the topic doesn't need to be replicated.

Specified by:

isMM2InternalTopic in interface ReplicationPolicy