Package org.apache.kafka.connect.mirror

package org.apache.kafka.connect.mirror

Provides APIs for the MirrorMaker connectors and utilities to manage MirrorMaker resources.

Class	Description
Checkpoint	Checkpoint records emitted by MirrorCheckpointConnector.
DefaultReplicationPolicy	Default implementation of ReplicationPolicy which prepends the source cluster alias to remote topic names.
Heartbeat	Heartbeat records emitted by MirrorHeartbeatConnector.
IdentityReplicationPolicy	Alternative implementation of ReplicationPolicy that does not rename remote topics.
MirrorClient	Client to interact with MirrorMaker internal topics (checkpoints, heartbeats) on a given cluster.
MirrorClientConfig	Configuration required for MirrorClient to talk to a given target cluster.
RemoteClusterUtils	Convenience tool for multi-cluster environments.
ReplicationPolicy	An interface used by the MirrorMaker connectors to manage topics names between source and target clusters.
SourceAndTarget	Directional pair of clusters, where source is mirrored to target.