Package org.apache.kafka.connect.mirror

package org.apache.kafka.connect.mirror
  • Class
    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".
    Directional pair of clusters, where source is replicated to target.