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 2022/12/07 11:09:37 UTC
[rocketmq-connect] branch master updated (5b9a8abc -> 568218e9)

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 5b9a8abc [ISSUE #366] Support for sftp connector（sinlk & source） (#382)
     add 568218e9 [RIP-45] Init replicator 2.0

No new revisions were added by this update.

Summary of changes:
 connectors/rocketmq-replicator/pom.xml             |  12 +
 .../replicator/ReplicatorHeartbeatConnector.java   | 109 ++++
 .../replicator/ReplicatorHeartbeatTask.java        | 264 ++++++++++
 .../replicator/ReplicatorSourceConnector.java      | 252 +++++++++
 .../rocketmq/replicator/ReplicatorSourceTask.java  | 579 +++++++++++++++++++++
 .../{DataType.java => ConsumeFromWhere.java}       |  15 +-
 .../{DataType.java => FailoverStrategy.java}       |  14 +-
 .../config/ReplicatorConnectorConfig.java          | 452 ++++++++++++++++
 .../replicator/exception/GetMetaDataException.java |  25 +-
 .../exception/InitMQClientException.java           |  25 +-
 .../ParamInvalidException.java}                    |  22 +-
 .../replicator/exception/StartTaskException.java   |  25 +-
 .../replicator/stats/ReplicatorTaskStats.java      |  82 +++
 .../rocketmq/replicator/utils/ReplicatorUtils.java |  60 +++
 .../connect/runtime/config/ConnectorConfig.java    |   3 +
 .../connect/runtime/stats/ConnectStatsManager.java |   4 +
 16 files changed, 1878 insertions(+), 65 deletions(-)
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java
 copy connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/{DataType.java => ConsumeFromWhere.java} (83%)
 copy connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/{DataType.java => FailoverStrategy.java} (88%)
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java
 copy rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/SourceConnectorConfig.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/GetMetaDataException.java (68%)
 copy rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/SourceConnectorConfig.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/InitMQClientException.java (68%)
 copy connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/{schema/FieldName.java => exception/ParamInvalidException.java} (72%)
 copy schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/TopicNameStrategy.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/exception/StartTaskException.java (69%)
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/stats/ReplicatorTaskStats.java
 create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java