You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mi...@apache.org on 2022/11/30 17:38:01 UTC
[kafka] branch trunk updated (d9946a7ffc1 -> 40af3a74507)

This is an automated email from the ASF dual-hosted git repository.

mimaison pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from d9946a7ffc1 MINOR: Fix config documentation formatting (#12921)
     add 40af3a74507 KAFKA-14413: Separate MirrorMaker configurations for each connector (#12899)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |  25 +-
 .../connect/mirror/MirrorCheckpointConfig.java     | 247 ++++++++++
 .../connect/mirror/MirrorCheckpointConnector.java  |  10 +-
 .../connect/mirror/MirrorCheckpointMetrics.java    | 110 +++++
 .../kafka/connect/mirror/MirrorCheckpointTask.java |   4 +-
 ...Config.java => MirrorCheckpointTaskConfig.java} |  44 +-
 .../connect/mirror/MirrorConnectorConfig.java      | 524 ++-------------------
 .../connect/mirror/MirrorHeartbeatConfig.java      |  88 ++++
 .../connect/mirror/MirrorHeartbeatConnector.java   |  10 +-
 .../kafka/connect/mirror/MirrorHeartbeatTask.java  |   2 +-
 .../kafka/connect/mirror/MirrorMakerConfig.java    |  26 +-
 .../kafka/connect/mirror/MirrorSourceConfig.java   | 312 ++++++++++++
 .../connect/mirror/MirrorSourceConnector.java      |  10 +-
 ...MirrorMetrics.java => MirrorSourceMetrics.java} |  69 +--
 .../kafka/connect/mirror/MirrorSourceTask.java     |   6 +-
 ...TaskConfig.java => MirrorSourceTaskConfig.java} |  26 +-
 .../kafka/connect/mirror/OffsetSyncStore.java      |   2 +-
 .../connect/mirror/MirrorCheckpointConfigTest.java |  84 ++++
 .../mirror/MirrorCheckpointConnectorTest.java      |  16 +-
 .../connect/mirror/MirrorConnectorConfigTest.java  | 208 +-------
 .../mirror/MirrorHeartBeatConnectorTest.java       |   4 +-
 .../connect/mirror/MirrorMakerConfigTest.java      |  55 ++-
 .../connect/mirror/MirrorSourceConfigTest.java     | 167 +++++++
 .../connect/mirror/MirrorSourceConnectorTest.java  |   5 +-
 .../kafka/connect/mirror/MirrorSourceTaskTest.java |   4 +-
 25 files changed, 1201 insertions(+), 857 deletions(-)
 create mode 100644 connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java
 create mode 100644 connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointMetrics.java
 copy connect/mirror/src/main/java/org/apache/kafka/connect/mirror/{MirrorTaskConfig.java => MirrorCheckpointTaskConfig.java} (59%)
 create mode 100644 connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorHeartbeatConfig.java
 create mode 100644 connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConfig.java
 rename connect/mirror/src/main/java/org/apache/kafka/connect/mirror/{MirrorMetrics.java => MirrorSourceMetrics.java} (73%)
 rename connect/mirror/src/main/java/org/apache/kafka/connect/mirror/{MirrorTaskConfig.java => MirrorSourceTaskConfig.java} (70%)
 create mode 100644 connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfigTest.java
 create mode 100644 connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConfigTest.java