Package org.apache.kafka.connect.mirror


package org.apache.kafka.connect.mirror
  • Class
    Description
    Checkpoint records emitted from MirrorCheckpointConnector.
    Defines remote topics like "us-west.topic1".
    Heartbeat message sent from MirrorHeartbeatTask to target cluster.
    IdentityReplicationPolicy does not rename remote topics.
    Interprets MM2's internal topics (checkpoints, heartbeats) on a given cluster.
    Configuration required for MirrorClient to talk to a given target cluster.
    Convenience methods for multi-cluster environments.
    Defines which topics are "remote topics". e.g.
    Directional pair of clusters, where source is replicated to target.