You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by ji...@apache.org on 2023/03/24 01:45:09 UTC

[rocketmq-connect] branch master updated (cdab185f -> 73a2f908)

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 cdab185f [ISSUE #392] Add iotdb source connector (#398)
     add 73a2f908 [ISSUE #441] Replicator optimize (#442)

No new revisions were added by this update.

Summary of changes:
 connectors/rocketmq-replicator/pom.xml             |   2 +-
 .../rocketmq/replicator/ReplicatorSourceTask.java  | 454 +++++++++++++++------
 .../config/ReplicatorConnectorConfig.java          |  14 +
 .../rocketmq/replicator/context/UnAckMessage.java  |  65 +++
 .../rocketmq/replicator/stats/TpsLimiter.java      |  82 ++++
 .../connect/runtime/common/LoggerName.java         |   5 +
 .../connectorwrapper/WorkerSinkTaskContext.java    |   4 +-
 .../connectorwrapper/WorkerSourceTaskContext.java  |   2 +-
 .../runtime/controller/isolation/PluginUtils.java  |   1 +
 .../controller/isolation/PluginWrapper.java        |  14 +
 .../src/main/resources/logback.xml                 |  81 ++++
 .../runtime/controller/isolation/PluginTest.java   |  11 +
 12 files changed, 608 insertions(+), 127 deletions(-)
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/context/UnAckMessage.java
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/stats/TpsLimiter.java