Versions Compared

Old Version 22

changes.mady.by.user Ryanne Dolan

Saved on

compared with

New Version 23

changes.mady.by.user Ryanne Dolan

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • MirrorSourceConnector, MirrorSinkConnector, MirrorSourceTask, MirrorSinkTask classes.

  • MirrorCheckpointConnector, MirrorCheckpointTask.
  • MirrorHeartbeatConnector, MirrorHeartbeatTask.
  • MirrorConnectorConfig, MirrorTaskConfig classes.

  • ReplicationPolicy interface. DefaultReplicationPolicy and LegacyReplicationPolicy classes.

  • Heartbeat and checkpoint topics and associated schemas.

  • RemoteClusterUtils class for querying remote cluster reachability and lag, and for translating consumer offsets between clusters.

  • MirrorMaker driver class with main entry point for running MM2 cluster nodes.

  • MirrorMakerConfig used by MirrorMaker driver.
  • ./bin/connect-mirror-maker.sh and ./config/mirror-maker.properties sample configuration.
  • MirrorMaker high-level REST API.

Proposed Changes

Remote Topics, Partitions

...