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