Package org.apache.kafka.connect.mirror

  • Interface Summary
    Interface Description
    ReplicationPolicy
    Defines which topics are "remote topics".
  • Class Summary
    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.
    SourceAndTarget
    Directional pair of clusters, where source is replicated to target.