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
