Package 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 Description static String
SEPARATOR_CONFIG
static String
SEPARATOR_DEFAULT
-
Constructor Summary
Constructors Constructor Description DefaultReplicationPolicy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(Map<String,?> props)
Configure this class with the given key-value pairsString
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
-
-
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 interfaceConfigurable
-
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 interfaceReplicationPolicy
-
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 interfaceReplicationPolicy
-
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 interfaceReplicationPolicy
-
-