This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
from 367790b4 [ISSUES #507] Optimize rebalance & optimize docker
add 85d9c036 [ISSUES #509] Replicator remove runtime dependency (#510)
No new revisions were added by this update.
Summary of changes:
.../rocketmq-connect-debezium-mysql/README.md | 4 +-
.../rocketmq-connect-debezium-postgresql/README.md | 4 +-
connectors/rocketmq-connect-doris/README.txt | 4 +-
.../README.md | 2 +-
connectors/rocketmq-replicator/README.md | 4 +-
connectors/rocketmq-replicator/pom.xml | 12 ++--
.../replicator/ReplicatorCheckpointConnector.java | 7 +-
.../replicator/ReplicatorCheckpointTask.java | 4 +-
.../replicator/ReplicatorHeartbeatConnector.java | 7 +-
.../replicator/ReplicatorHeartbeatTask.java | 3 -
.../replicator/ReplicatorSourceConnector.java | 11 ++-
.../rocketmq/replicator/ReplicatorSourceTask.java | 40 ++---------
.../rocketmq/replicator/common/LoggerName.java | 52 +++++++-------
.../config/ReplicatorConnectorConfig.java | 7 +-
.../replicator/stats/ReplicatorTaskStats.java | 82 ----------------------
.../rocketmq/replicator/utils/ReplicatorUtils.java | 16 ++++-
.../service/AbstractConfigManagementService.java | 1 +
.../store/ConnectKeyValueDeserializerTest.java | 4 +-
.../store/ConnectKeyValueSerializerTest.java | 2 +-
19 files changed, 85 insertions(+), 181 deletions(-)
copy
rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/CLIConfigDefine.java
=>
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java
(75%)
delete mode 100644
connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/stats/ReplicatorTaskStats.java
