Package org.apache.kafka.connect.mirror

package org.apache.kafka.connect.mirror

Class	Description
Checkpoint	Checkpoint records emitted from MirrorCheckpointConnector.
DefaultReplicationPolicy	Defines remote topics like "us-west.topic1".
Heartbeat	Heartbeat message sent from MirrorHeartbeatTask to target cluster.
IdentityReplicationPolicy	IdentityReplicationPolicy does not rename remote topics.
MirrorClient	Interprets MM2's internal topics (checkpoints, heartbeats) on a given cluster.
MirrorClientConfig	Configuration required for MirrorClient to talk to a given target cluster.
RemoteClusterUtils	Convenience methods for multi-cluster environments.
ReplicationPolicy	Defines which topics are "remote topics". e.g.
SourceAndTarget	Directional pair of clusters, where source is replicated to target.