You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 06:15:07 UTC
[rocketmq-connect] 09/10: Add 'connectors/rocketmq-replicator/' from commit '55631bb1fe4d3864c2d45dc7fee9e49764d7b3ac'
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 0e15ffa030cceae05ed4517289b2df09daa5fc48
Merge: fb6e085 55631bb
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:58 2022 +0800
Add 'connectors/rocketmq-replicator/' from commit '55631bb1fe4d3864c2d45dc7fee9e49764d7b3ac'
git-subtree-dir: connectors/rocketmq-replicator
git-subtree-mainline: fb6e0852880c6b37fe734b8a8048379e1489456a
git-subtree-split: 55631bb1fe4d3864c2d45dc7fee9e49764d7b3ac
connectors/rocketmq-replicator/.gitignore | 13 +
connectors/rocketmq-replicator/README.md | 69 +++++
connectors/rocketmq-replicator/package.xml | 41 +++
connectors/rocketmq-replicator/pom.xml | 154 ++++++++++
.../apache/rocketmq/replicator/MetaSourceTask.java | 156 ++++++++++
.../apache/rocketmq/replicator/RmqConstants.java | 38 +++
.../rocketmq/replicator/RmqMetaReplicator.java | 254 ++++++++++++++++
.../rocketmq/replicator/RmqSourceReplicator.java | 333 +++++++++++++++++++++
.../apache/rocketmq/replicator/RmqSourceTask.java | 273 +++++++++++++++++
.../rocketmq/replicator/common/ConstDefine.java | 29 ++
.../apache/rocketmq/replicator/common/Utils.java | 203 +++++++++++++
.../rocketmq/replicator/config/ConfigDefine.java | 68 +++++
.../rocketmq/replicator/config/ConfigUtil.java | 70 +++++
.../rocketmq/replicator/config/DataType.java | 26 ++
.../replicator/config/RmqConnectorConfig.java | 172 +++++++++++
.../rocketmq/replicator/config/TaskConfig.java | 133 ++++++++
.../rocketmq/replicator/config/TaskConfigEnum.java | 48 +++
.../replicator/config/TaskDivideConfig.java | 123 ++++++++
.../rocketmq/replicator/config/TaskTopicInfo.java | 37 +++
.../rocketmq/replicator/offset/OffsetSync.java | 75 +++++
.../replicator/offset/OffsetSyncStore.java | 90 ++++++
.../rocketmq/replicator/schema/FieldName.java | 32 ++
.../replicator/strategy/DivideStrategyEnum.java | 23 ++
.../strategy/DivideTaskByConsistentHash.java | 89 ++++++
.../replicator/strategy/DivideTaskByQueue.java | 65 ++++
.../replicator/strategy/DivideTaskByTopic.java | 60 ++++
.../replicator/strategy/TaskDivideStrategy.java | 29 ++
.../replicator/RmqSourceReplicatorTest.java | 66 ++++
28 files changed, 2769 insertions(+)
diff --cc connectors/rocketmq-replicator/.gitignore
index 0000000,525eaaa..525eaaa
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/.gitignore
+++ b/connectors/rocketmq-replicator/.gitignore
diff --cc connectors/rocketmq-replicator/README.md
index 0000000,16b01c5..16b01c5
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/README.md
+++ b/connectors/rocketmq-replicator/README.md
diff --cc connectors/rocketmq-replicator/package.xml
index 0000000,5dc18b9..5dc18b9
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/package.xml
+++ b/connectors/rocketmq-replicator/package.xml
diff --cc connectors/rocketmq-replicator/pom.xml
index 0000000,c7a08a3..c7a08a3
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/pom.xml
+++ b/connectors/rocketmq-replicator/pom.xml
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java
index 0000000,67fc89f..67fc89f
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqConstants.java
index 0000000,290ab1c..290ab1c
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqConstants.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqConstants.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java
index 0000000,bbf3527..bbf3527
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
index 0000000,ecbedb6..ecbedb6
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java
index 0000000,ca7edb4..ca7edb4
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/ConstDefine.java
index 0000000,83583ca..83583ca
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/ConstDefine.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/ConstDefine.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java
index 0000000,30dc214..30dc214
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigDefine.java
index 0000000,b4de086..b4de086
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigDefine.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigDefine.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigUtil.java
index 0000000,5da92bc..5da92bc
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigUtil.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigUtil.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/DataType.java
index 0000000,60dc330..60dc330
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/DataType.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/DataType.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java
index 0000000,2d4fc2a..2d4fc2a
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java
index 0000000,7921585..7921585
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfigEnum.java
index 0000000,520c31f..520c31f
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfigEnum.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfigEnum.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java
index 0000000,b8d6fe5..b8d6fe5
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
index 0000000,b791b93..b791b93
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java
index 0000000,51c29a7..51c29a7
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSyncStore.java
index 0000000,f8c4b6a..f8c4b6a
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSyncStore.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSyncStore.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/FieldName.java
index 0000000,a8acd08..a8acd08
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/FieldName.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/FieldName.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideStrategyEnum.java
index 0000000,fb46be3..fb46be3
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideStrategyEnum.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideStrategyEnum.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByConsistentHash.java
index 0000000,708a5b0..708a5b0
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByConsistentHash.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByConsistentHash.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java
index 0000000,bbfa580..bbfa580
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByTopic.java
index 0000000,0d13a5e..0d13a5e
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByTopic.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByTopic.java
diff --cc connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/TaskDivideStrategy.java
index 0000000,89ed060..89ed060
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/TaskDivideStrategy.java
+++ b/connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/TaskDivideStrategy.java
diff --cc connectors/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/RmqSourceReplicatorTest.java
index 0000000,795c386..795c386
mode 000000,100644..100644
--- a/connectors/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/RmqSourceReplicatorTest.java
+++ b/connectors/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/RmqSourceReplicatorTest.java