org.apache.kafka.connect.mirror

Class DefaultReplicationPolicy

java.lang.Object

org.apache.kafka.connect.mirror.DefaultReplicationPolicy

All Implemented Interfaces:

Configurable, ReplicationPolicy

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 and Description
static String	SEPARATOR_CONFIG
static String	SEPARATOR_DEFAULT

Constructor Summary

Constructors

Constructor and Description
DefaultReplicationPolicy()

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) How to rename remote topics; generally should be like us-west.topic1.
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

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

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

isInternalTopic, originalTopic

Field Detail

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

Constructor Detail

DefaultReplicationPolicy

public DefaultReplicationPolicy()

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

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