See: Description
| Interface | Description |
|---|---|
| ReplicationPolicy |
An interface used by the MirrorMaker connectors to manage topics names between source and target clusters.
|
| 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.
|
| SourceAndTarget |
Directional pair of clusters, where source is mirrored to target.
|