Checkpoint |
Checkpoint records emitted from MirrorCheckpointConnector.
|
DefaultReplicationPolicy |
Defines remote topics like "us-west.topic1".
|
Heartbeat |
Heartbeat message sent from MirrorHeartbeatTask to target cluster.
|
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.
|
SourceAndTarget |
Directional pair of clustes, where source is replicated to target.
|