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:14:58 UTC
[rocketmq-connect] branch master updated (a1e5f60 -> 08fb705)
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git.
from a1e5f60 Merge branch 'rocketmq_connect1' of https://github.com/apache/rocketmq-externals
add e2cc843 [ISSUE #570] ASoC runtime optimization: Cassandra connectors (#587)
new 796adf1 Add 'connectors/rocketmq-connect-cassandra/' from commit 'e2cc843ef4926a98797ca76880579941d5363fc6'
add 44bb9bd [ISSUE #801]Rocketmq connector sink for hudi (#800)
add 5da4b78 fix hudi connect config
new 11d2b68 Add 'connectors/rocketmq-connect-hudi/' from commit '5da4b78705108ac6d260283cd38f9be08d2590b9'
add a9fb3af Init rocketmq-connect-jdbc
add 13b6ae3 Add Jdbc Source Connector and Do Unit Test
add 9716b10 Update pom.xml
add 5db4b46 Update Config.java
add 675099d Update JdbcSourceConnector.java
add 3c5f659 Add Jdbc Source Task (To be continued)
add 2cc48d9 Add Config File
add 5a83890 Add JdbcSourceTask
add e915f67 Add JdbcSourceTask and Schema
add 9ea583f Add SourceJdbcTask and Schema
add 8ecde45 Add JdbcSourceTask and Schema
add a1d1200 Delete ReplicatorTest.java
add b1acd43 delete lib
add 488223c develop the jdbcsource connector
add d0569b7 Update Querier.java
add cd6410d Update JdbcSourceConnectorTest.java
add 1376d82 Develop TimestampIncrementingQuerier Mode
add 4849ff5 Update TimestampIncrementingQuerier.java
add e72688b Update Querier.java
add 0521831 Delete JdbcSourceTaskTest.java
add 8a266e8 update readme
add 717d4a2 Update Schema.java
add 5457c06 Update JdbcSourceTask.java
add db7644a Update JdbcSourceTask.java
add 182fd46 [ISSUE #441] Add Jdbc Sink Connector (#442)
add 42cbfb3 [ISSUE #485] Support repeat consumption (#486)
add d06e10c [ISSUE #487] Jdbc source connector support syncing data with white ta… (#488)
add 759e422 [ISSUE #498] update rocketmq-jdbc-connector README.md (#499)
add 341d6f3 [ISSUE #489] JDBC Connector support divide task by topic strategy (#490)
add 252e26a [ISSUE #495] jdbc-sink-connector support divide task by queue (#496)
add 7c81b41 Update connector dependency to the latest version
add 7ebfedf fix(jdbc-connect) removed unused class
add b9802ae fix(jdbc-connect) removed unused class (#544)
add e325d72 1.add rocketmq-tools dependency so rocketmq-connect-jdbc can run on it (#537)
add 5420e44 1.add required fields in RockeMQ jdbc connector 2. add docs (#539)
add 0b56e47 [ISSUE #545]bug fix (#546)
add a1f2ff2 [ISSUE #550] Removed unnecessary value of REQUEST_CONFIG in Config.java (#551)
add 9849db6 [ISSUE #554] Update druid version and set ConnectionErrorRetryAttempts
add 1a49e60 [ISSUE #558] An ugly solution for fetch topic list error
add b425260 [ISSUE #570] ASoC connect runtime optimization: CLI (#622)
add 5f40a88 Update README.md (#553)
add 6708ada Merge branch 'master' of github.com:apache/rocketmq-externals
new cbb84d7 Add 'connectors/rocketmq-connect-jdbc/' from commit '6708ada617d9f6cfef5ca42a3c2f97af44603a89'
add 8b8c95f Initial rocketmq-connect-jms project
add 78cc902 [ISSUE #302] Implement rocketmq connect jms (#303)
add 6801219 [ISSUE #312] Implement rocketmq connect RabbitMQ (#313)
add 4e3ccda fix(connect-runtime) remove unused local variable
add 37a4db7 fix(connect-jms) should put .iml file in gitignore
new 8ad0704 Add 'connectors/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'
add d0ff0aa Init rocketmq-kafka connect project
add bbb1202 rocketmq-connect-kafka
add 9aa0640 Update README.md for rocketmq-connect-kafka (#338)
add 598de5d [ISSUE #341] Add wakeup before kafka consumer close to wakeup consumer poll (#342)
add e74c022 [ISSUE #420]remove openmessage-runtime dependency
add 59ac9fd [rocketmq-connect-kafka]: Completion method KafkaSourceTask#pause(), KafkaSourceTask#resume(). (#854)
new e2861dc Add 'connectors/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
add f629088 add junit test and modify some code
add 6ca400a add junit test and modify some code
add e84812e 修改stop
add 32d3165 fix some bug
add 70caed3 fix some bug
add 6777f23 fix bug
add f95bf22 support multiple mongo replicaset
add 98da0fb fix test verifyConfig
add f193fcd reformat code and add more test case
add 2cdb27a fix some bug and add readme
add db51f7f clean code
add b307466 bump up the connect version to 0.1.1
new d0bd4f0 Add 'connectors/rocketmq-connect-mongo/' from commit 'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
add 4e42a37 Initial rocketmq-connect-rabbitmq
add a7ab1c4 [ISSUE #312] Implement rocketmq connect RabbitMQ (#313)
new 3f900aa Add 'connectors/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
add 8862e3e Init rocketmq-connect-redis
add 14da1d8 Add Redis connector. (#403)
add 1290dde Support redis 6 (#510)
add 18f2061 bump up the connect version to 0.1.1
add ed629ae update rocketmq-connect-redis dependency (#583)
add 8a07d71 Update rocketmq-connect-redis pom.xml (#592)
add 4fdd8b2 Fix exception parsing redis command "set a 1010 px 1000" (#862)
new fb6e085 Add 'connectors/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
add 952aa8f (1)Rename rocketmq-connector to replicator (2) Initialize RocketMQ activemq connect and runtime
add 208e4ed init commit (#309)
add 6ddd7e4 Define and Implement the RmqConnector and RmqSourceTask. (#343)
add c7a2c41 [ISSUE #351] rmq client setInstanceName on sourceTask (#355)
add 25e699e return taskConfig with source-record-converter (#373)
add c1a51cc 【ISSUE #278】Define and Implement the RmqConnector and RmqSourceTask. (#381)
add 40b9fc8 [ISSUE 368]Polish rocketmq replicator implementation (#366)
add ef2a365 Update README.md
add d80142a Support wildcard subscription topic. resolve #395
add b4f8cd9 Automatically create target topic. resolve #396
add 81376b9 Topic rename. resolve #399
add ad38ec7 extend messageQueue for TaskTopicInfo
add 90541a2 add DivideTaskByQueue. resolve #397
add d4e677d fix sourceTaskTopicList is null. resolve #386
add 6809200 Merge pull request #422 from xujianhai666/fix-emptyTopic
add ebb44c1 Increase topic change awareness monitoring. resolve #398
add caea266 Merge pull request #424 from xujianhai666/feat-queuelistener
add dfb32fd chore(runtime/replicator): change rocketmq dependency from 4.4.0 to 4.5.2
add a321762 feat(replicator):add consumer offset sync
add d7b0ce8 feat(replicator): Support subcriptionConfig sync
add b3377a6 [ISSUES #434] Replicator support RocketMQConverter (#463)
add 2d00797 feat(replicator): support DivideTaskByConsistentHash (#443)
add ff09b42 feat(replicator): Add commitRecord after producer send success (#452)
add 6182624 When replicator stop, stop MQAdminExt and Listener (#474)
add 5ed354b The topic name in the TaskTopicInfo constructor should be topic (#473)
add 7201d00 [ISSUE #468] Replicator is packaged as fatjar (#472)
add f55d213 [ISSUE #478] TopicList is null exception and frequent requestTaskReconfiguration (#483)
add 070dd98 [ISSUE #492] Optimize metadata synchronization and fix RocketMQConverter bug (#493)
add ae2751e [ISSUE 503] Metadata synchronization optimization (#504)
add d2e168e Supplemental replicator documentation (#506)
add b0ca555 docs(replicator): add introduction of replicator (#507)
add 2e8ea2e Update README.md
add 8e66fd6 [Replicator] Fix message duplication problem (#692)
add a0b10aa [ISSUE #699] [Replicator] The source task starts to check the position (#700)
add 1ca3a07 [rocketmq-replicator] Support ACL (#832)
add 691ff01 [rocketmq-replicator] Bug fix: Missing subscription group when syncing offset (#837)
add d1845c5 [rocketmq-replicator] Fix topic build route logic (#834)
add 55631bb [rocketmq-replicator] Support subGroup whitelist (#843)
new 0e15ffa Add 'connectors/rocketmq-replicator/' from commit '55631bb1fe4d3864c2d45dc7fee9e49764d7b3ac'
add f4221ce (1)Rename rocketmq-connector to replicator (2) Initialize RocketMQ activemq connect and runtime
add c7c0c04 init complete
add 30b02f4 change package name
add da0b21f change
add 6663768 change
add d50ffb8 message type
add 508eea1 add unit test
add 23a5b24 add licenses
add db391c5 change exception
add 3da8a3f format pom.xml
add e8aedf3 Change README.md (#301)
new 08fb705 Add 'connectors/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
connectors/rocketmq-connect-activemq/README-CN.md | 16 +
connectors/rocketmq-connect-activemq/README.md | 16 +
.../rocketmq-connect-activemq}/pom.xml | 134 +--
.../apache/rocketmq/connect/activemq/Config.java | 109 +-
.../rocketmq/connect/activemq/ErrorCode.java | 8 +
.../rocketmq/connect/activemq/Replicator.java | 63 ++
.../connector/ActivemqSourceConnector.java | 28 +-
.../activemq/connector/ActivemqSourceTask.java | 141 +++
.../connect/activemq/pattern/PatternProcessor.java | 89 ++
.../rocketmq/connect/activemq/ReplicatorTest.java | 74 ++
.../activemq/connector/ActivemqConnectorTest.java | 58 +
.../activemq/connector/ActivemqSourceTaskTest.java | 165 +++
connectors/rocketmq-connect-cassandra/README.md | 97 ++
.../rocketmq-connect-cassandra}/pom.xml | 197 ++--
.../rocketmq-connect-cassandra/scripts/gen_data.py | 155 +++
.../scripts/requirements.txt | 2 +
.../connect/cassandra/common/CloneUtils.java | 44 +
.../connect/cassandra/common/ConstDefine.java | 17 +-
.../rocketmq/connect/cassandra/common/DBUtils.java | 91 ++
.../connect/cassandra/common/DataType.java | 20 +-
.../rocketmq/connect/cassandra/common/Utils.java | 76 ++
.../rocketmq/connect/cassandra/config/Config.java | 282 +++++
.../connect/cassandra/config/ConfigUtil.java | 24 +-
.../cassandra/config/DbConnectorConfig.java | 110 ++
.../cassandra/config/SinkDbConnectorConfig.java | 112 ++
.../cassandra/config/SourceDbConnectorConfig.java | 87 ++
.../connect/cassandra/config/TaskDivideConfig.java | 123 +++
.../connect/cassandra/config/TaskTopicInfo.java | 84 +-
.../connector/CassandraSinkConnector.java | 240 +++++
.../cassandra/connector/CassandraSinkTask.java | 161 +++
.../connector/CassandraSourceConnector.java | 108 ++
.../cassandra/connector/CassandraSourceTask.java | 168 +++
.../connect/cassandra/schema/Database.java | 140 +++
.../rocketmq/connect/cassandra/schema/Schema.java | 146 +++
.../rocketmq/connect/cassandra/schema/Table.java | 103 ++
.../schema/column/BigIntColumnParser.java | 43 +-
.../schema/column/BooleanColumnParser.java | 33 +-
.../cassandra/schema/column/ColumnParser.java | 118 +++
.../schema/column/DateTimeColumnParser.java | 53 +
.../schema/column/DefaultColumnParser.java | 32 +-
.../cassandra/schema/column/EnumColumnParser.java | 43 +-
.../cassandra/schema/column/IntColumnParser.java | 66 ++
.../cassandra/schema/column/SetColumnParser.java | 54 +
.../schema/column/StringColumnParser.java | 57 +
.../cassandra/schema/column/TimeColumnParser.java | 32 +-
.../cassandra/schema/column/YearColumnParser.java | 35 +-
.../rocketmq/connect/cassandra/sink/Updater.java | 216 ++++
.../rocketmq/connect/cassandra/source/Querier.java | 164 +++
.../cassandra/strategy/DivideStrategyEnum.java | 17 +-
.../cassandra/strategy/DivideTaskByTopic.java | 110 ++
.../cassandra/strategy/TaskDivideStrategy.java | 33 +-
connectors/rocketmq-connect-hudi/README.md | 77 ++
.../rocketmq-connect-hudi}/pom.xml | 228 ++--
.../rocketmq/connect/hudi/config/CloneUtils.java | 50 +
.../rocketmq/connect/hudi/config/ConfigUtil.java | 24 +-
.../connect/hudi/config/HudiConnectConfig.java | 173 +++
.../connect/hudi/config/SinkConnectConfig.java | 139 +++
.../apache/rocketmq/connect/hudi/config/Utils.java | 75 ++
.../connect/hudi/connector/HudiSinkConnector.java | 250 +++++
.../connect/hudi/connector/HudiSinkTask.java | 111 ++
.../apache/rocketmq/connect/hudi/sink/Updater.java | 239 +++++
.../connect/hudi/strategy/ITaskDivideStrategy.java | 28 +-
.../hudi/strategy/TaskDivideByQueueStrategy.java | 80 ++
.../hudi/strategy/TaskDivideStrategyFactory.java | 12 +-
.../style}/rmq_checkstyle.xml | 6 -
connectors/rocketmq-connect-jdbc/README.md | 85 ++
.../rocketmq-connect-jdbc}/pom.xml | 194 ++--
.../rocketmq/connect/jdbc/common/CloneUtils.java | 28 +
.../rocketmq/connect/jdbc/common/ConstDefine.java | 17 +-
.../rocketmq/connect/jdbc/common/DBUtils.java | 212 ++++
.../apache/rocketmq/connect/jdbc/common/Utils.java | 74 ++
.../rocketmq/connect/jdbc/config/Config.java | 357 +++++++
.../rocketmq/connect/jdbc/config/ConfigUtil.java | 28 +-
.../rocketmq/connect/jdbc/config/DataType.java | 20 +-
.../connect/jdbc/config/DbConnectorConfig.java | 84 ++
.../connect/jdbc/config/SinkDbConnectorConfig.java | 98 ++
.../jdbc/config/SourceDbConnectorConfig.java | 73 ++
.../connect/jdbc/config/TaskDivideConfig.java | 112 ++
.../connect/jdbc/config/TaskTopicInfo.java | 32 +-
.../connect/jdbc/connector/JdbcSinkConnector.java | 221 ++++
.../connect/jdbc/connector/JdbcSinkTask.java | 134 +++
.../jdbc/connector/JdbcSourceConnector.java | 105 ++
.../connect/jdbc/connector/JdbcSourceTask.java | 183 ++++
.../rocketmq/connect/jdbc/schema/Database.java | 109 ++
.../rocketmq/connect/jdbc/schema/Schema.java | 123 +++
.../apache/rocketmq/connect/jdbc/schema/Table.java | 101 ++
.../jdbc/schema/column/BigIntColumnParser.java | 43 +-
.../connect/jdbc/schema/column/ColumnParser.java | 104 ++
.../jdbc/schema/column/DateTimeColumnParser.java | 53 +
.../jdbc/schema/column/DefaultColumnParser.java | 32 +-
.../jdbc/schema/column/EnumColumnParser.java | 43 +-
.../jdbc/schema/column/IntColumnParser.java | 66 ++
.../jdbc/schema/column/SetColumnParser.java | 54 +
.../jdbc/schema/column/StringColumnParser.java | 57 +
.../jdbc/schema/column/TimeColumnParser.java | 32 +-
.../jdbc/schema/column/YearColumnParser.java | 35 +-
.../apache/rocketmq/connect/jdbc/sink/Updater.java | 258 +++++
.../rocketmq/connect/jdbc/source/Querier.java | 173 +++
.../jdbc/source/TimestampIncrementingQuerier.java | 311 ++++++
.../connect/jdbc/strategy/DivideStrategyEnum.java | 17 +-
.../connect/jdbc/strategy/DivideTaskByQueue.java | 72 ++
.../connect/jdbc/strategy/DivideTaskByTopic.java | 113 ++
.../connect/jdbc/strategy/TaskDivideStrategy.java | 31 +-
.../jdbc/connector/JdbcSourceConnectorTest.java | 79 ++
.../rocketmq-connect-jms}/pom.xml | 131 +--
.../org/apache/rocketmq/connect/jms/Config.java | 109 +-
.../org/apache/rocketmq/connect/jms/ErrorCode.java | 8 +
.../apache/rocketmq/connect/jms/Replicator.java | 67 ++
.../jms/connector/BaseJmsSourceConnector.java | 33 +-
.../connect/jms/connector/BaseJmsSourceTask.java | 150 +++
.../connect/jms/pattern/PatternProcessor.java | 90 ++
.../jms/connector/BaseJmsSourceConnectorTest.java | 82 ++
connectors/rocketmq-connect-kafka/README.md | 30 +
.../rocketmq-connect-kafka}/pom.xml | 126 +--
.../connect/kafka/config/ConfigDefine.java | 67 ++
.../rocketmq/connect/kafka/config/ConfigUtil.java | 14 +-
.../kafka/connector/KafkaSourceConnector.java | 104 ++
.../connect/kafka/connector/KafkaSourceTask.java | 250 +++++
.../main/resources/connect-kafka-source.properties | 12 +-
.../kafka/connector/KafkaSourceConnectorTest.java | 57 +
.../kafka/connector/KafkaSourceTaskTest.java | 38 +-
connectors/rocketmq-connect-mongo/README.md | 43 +
.../rocketmq-connect-mongo}/pom.xml | 102 +-
.../org/apache/connect/mongo/SourceTaskConfig.java | 266 +++++
.../mongo/connector/MongoSourceConnector.java | 44 +-
.../connect/mongo/connector/MongoSourceTask.java | 105 ++
.../mongo/connector/builder/MongoDataEntry.java | 134 +++
.../connect/mongo/initsync/CollectionMeta.java | 58 +
.../apache/connect/mongo/initsync/InitSync.java | 163 +++
.../apache/connect/mongo/replicator/Constants.java | 37 +-
.../mongo/replicator/MongoClientFactory.java | 129 +++
.../connect/mongo/replicator/OperationFilter.java | 80 ++
.../apache/connect/mongo/replicator/Position.java | 85 ++
.../connect/mongo/replicator/ReplicaSet.java | 112 ++
.../connect/mongo/replicator/ReplicaSetConfig.java | 75 ++
.../mongo/replicator/ReplicaSetManager.java | 85 ++
.../mongo/replicator/ReplicaSetsContext.java | 121 +++
.../connect/mongo/replicator/ReplicatorTask.java | 128 +++
.../replicator/event/Document2EventConverter.java | 49 +
.../mongo/replicator/event/OperationType.java | 62 ++
.../mongo/replicator/event/ReplicationEvent.java | 176 ++++
.../java/org/apache/connect/mongo/FilterTest.java | 67 ++
.../org/apache/connect/mongo/MongoFactoryTest.java | 177 ++++
.../connect/mongo/MongoSourceConnectorTest.java | 95 ++
.../apache/connect/mongo/MongoSourceTaskTest.java | 142 +++
.../java/org/apache/connect/mongo/MongoTest.java | 138 +++
.../apache/connect/mongo/OperationTypeTest.java | 37 +
.../apache/connect/mongo/ReplicaContextTest.java | 33 +
.../connect/mongo/ReplicaSetManagerTest.java | 58 +
.../org/apache/connect/mongo/ReplicaSetTest.java | 59 ++
connectors/rocketmq-connect-rabbitmq/README.md | 17 +
connectors/rocketmq-connect-rabbitmq/pom.xml | 205 ++++
.../rocketmq/connect/rabbitmq/ErrorCode.java | 8 +
.../rocketmq/connect/rabbitmq/RabbitmqConfig.java | 61 ++
.../connector/RabbitmqSourceConnector.java | 30 +-
.../rabbitmq/connector/RabbitmqSourceTask.java | 34 +-
.../rabbitmq/pattern/RabbitMQPatternProcessor.java | 48 +
.../rocketmq/connect/jms/RabbitmqConfigTest.java | 18 +-
.../connector/RabbitmqSourceConnectorTest.java | 54 +
.../rabbitmq/connector/RabbitmqSourceTaskTest.java | 164 +++
.../pattern/RabbitMQPatternProcessorTest.java | 36 +-
connectors/rocketmq-connect-redis/README-CN.md | 19 +
connectors/rocketmq-connect-redis/README.md | 19 +
.../rocketmq-connect-redis}/pom.xml | 185 ++--
.../rocketmq/connect/redis/common/Config.java | 237 +++++
.../rocketmq/connect/redis/common/Options.java | 124 +++
.../connect/redis/common/RedisConstants.java | 46 +
.../rocketmq/connect/redis/common/SyncMod.java | 48 +-
.../redis/connector/RedisSourceConnector.java | 42 +-
.../connect/redis/connector/RedisSourceTask.java | 148 +++
.../connect/redis/converter/KVEntryConverter.java | 16 +-
.../redis/converter/RedisEntryConverter.java | 134 +++
.../redis/converter/RedisPositionConverter.java | 54 +
.../redis/handler/DefaultRedisEventHandler.java | 174 +++
.../connect/redis/handler/RedisEventHandler.java | 72 ++
.../redis/parser/AbstractCommandParser.java | 82 ++
.../connect/redis/parser/AppendParser.java | 29 +-
.../connect/redis/parser/BitFieldParser.java | 31 +-
.../rocketmq/connect/redis/parser/BitOpParser.java | 34 +-
.../connect/redis/parser/BrPopLPushParser.java | 34 +-
.../connect/redis/parser/CommonParser.java | 117 +++
.../connect/redis/parser/DecrByParser.java | 31 +-
.../rocketmq/connect/redis/parser/DecrParser.java | 31 +-
.../redis/parser/DefaultRedisRdbParser.java | 197 ++++
.../rocketmq/connect/redis/parser/DelParser.java | 39 +-
.../rocketmq/connect/redis/parser/EvalParser.java | 29 +-
.../connect/redis/parser/EvalShaParser.java | 29 +-
.../rocketmq/connect/redis/parser/ExecParser.java | 31 +-
.../connect/redis/parser/ExpireAtParser.java | 31 +-
.../connect/redis/parser/ExpireParser.java | 33 +-
.../connect/redis/parser/FlushAllParser.java | 31 +-
.../connect/redis/parser/FlushDbParser.java | 30 +-
.../connect/redis/parser/GeoAddParser.java | 49 +
.../connect/redis/parser/GetsetParser.java | 30 +-
.../rocketmq/connect/redis/parser/HDelParser.java | 34 +-
.../connect/redis/parser/HIncrByParser.java | 34 +-
.../connect/redis/parser/HSetNxParser.java | 30 +-
.../rocketmq/connect/redis/parser/HSetParser.java | 30 +-
.../rocketmq/connect/redis/parser/HmSetParser.java | 30 +-
.../connect/redis/parser/IncrByParser.java | 31 +-
.../rocketmq/connect/redis/parser/IncrParser.java | 31 +-
.../rocketmq/connect/redis/parser/LPopParser.java | 31 +-
.../rocketmq/connect/redis/parser/LPushParser.java | 34 +-
.../connect/redis/parser/LPushXParser.java | 30 +-
.../rocketmq/connect/redis/parser/LRemParser.java | 34 +-
.../rocketmq/connect/redis/parser/LSetParser.java | 34 +-
.../rocketmq/connect/redis/parser/LTrimParser.java | 34 +-
.../connect/redis/parser/LinsertParser.java | 51 +
.../connect/redis/parser/MSetNxParser.java | 30 +-
.../rocketmq/connect/redis/parser/MSetParser.java | 30 +-
.../rocketmq/connect/redis/parser/MoveParser.java | 31 +-
.../rocketmq/connect/redis/parser/MultiParser.java | 31 +-
.../connect/redis/parser/PExpireAtParser.java | 31 +-
.../connect/redis/parser/PExpireParser.java | 31 +-
.../connect/redis/parser/PSetExParser.java | 34 +-
.../rocketmq/connect/redis/parser/Parser.java | 16 +-
.../connect/redis/parser/PersistParser.java | 31 +-
.../rocketmq/connect/redis/parser/PfAddParser.java | 34 +-
.../connect/redis/parser/PfCountParser.java | 30 +-
.../connect/redis/parser/PfMergeParser.java | 34 +-
.../connect/redis/parser/PublishParser.java | 30 +-
.../connect/redis/parser/RPopLPushParser.java | 30 +-
.../rocketmq/connect/redis/parser/RPopParser.java | 31 +-
.../rocketmq/connect/redis/parser/RPushParser.java | 34 +-
.../connect/redis/parser/RPushXParser.java | 30 +-
.../connect/redis/parser/RedisRdbParser.java | 67 ++
.../connect/redis/parser/RenameNxParser.java | 30 +-
.../connect/redis/parser/RenameParser.java | 30 +-
.../connect/redis/parser/RestoreParser.java | 38 +-
.../rocketmq/connect/redis/parser/SAddParser.java | 34 +-
.../connect/redis/parser/SDiffStoreParser.java | 34 +-
.../connect/redis/parser/SInterStoreParser.java | 34 +-
.../rocketmq/connect/redis/parser/SMoveParser.java | 34 +-
.../rocketmq/connect/redis/parser/SRemParser.java | 34 +-
.../connect/redis/parser/SUnionStoreParser.java | 34 +-
.../connect/redis/parser/ScriptParser.java | 31 +-
.../connect/redis/parser/SelectParser.java | 31 +-
.../connect/redis/parser/SetBitParser.java | 34 +-
.../rocketmq/connect/redis/parser/SetExParser.java | 35 +-
.../rocketmq/connect/redis/parser/SetNxParser.java | 30 +-
.../rocketmq/connect/redis/parser/SetParser.java | 59 ++
.../connect/redis/parser/SetRangeParser.java | 34 +-
.../rocketmq/connect/redis/parser/SortParser.java | 31 +-
.../connect/redis/parser/SwapDbParser.java | 31 +-
.../connect/redis/parser/UnLinkParser.java | 30 +-
.../rocketmq/connect/redis/parser/XAckParser.java | 49 +
.../rocketmq/connect/redis/parser/XAddParser.java | 39 +-
.../connect/redis/parser/XClaimParser.java | 88 ++
.../rocketmq/connect/redis/parser/XDelParser.java | 34 +-
.../connect/redis/parser/XGroupParser.java | 31 +-
.../connect/redis/parser/XSetIdParser.java | 30 +-
.../rocketmq/connect/redis/parser/XTrimParser.java | 36 +-
.../rocketmq/connect/redis/parser/ZAddParser.java | 69 ++
.../connect/redis/parser/ZIncrByParser.java | 34 +-
.../connect/redis/parser/ZInterStoreParser.java | 30 +-
.../connect/redis/parser/ZPopMaxParser.java | 31 +-
.../connect/redis/parser/ZPopMinParser.java | 31 +-
.../rocketmq/connect/redis/parser/ZRemParser.java | 34 +-
.../connect/redis/parser/ZRemRangeByLexParser.java | 34 +-
.../redis/parser/ZRemRangeByRankParser.java | 34 +-
.../redis/parser/ZRemRangeByScoreParser.java | 34 +-
.../connect/redis/parser/ZUnionStoreParser.java | 30 +-
.../apache/rocketmq/connect/redis/pojo/Geo.java | 37 +-
.../rocketmq/connect/redis/pojo/KVEntry.java | 71 ++
.../rocketmq/connect/redis/pojo/RedisEntry.java | 171 +++
.../rocketmq/connect/redis/pojo/RedisEvent.java | 42 +-
.../processor/DefaultRedisEventProcessor.java | 453 ++++++++
.../redis/processor/RedisClosedListener.java | 34 +-
.../redis/processor/RedisEventListener.java | 121 +++
.../redis/processor/RedisEventProcessor.java | 33 +-
.../processor/RedisEventProcessorCallback.java | 15 +-
.../redis/processor/RedisExceptionListener.java | 44 +
.../connect/redis/util/ParseStringUtils.java | 54 +
.../connect/redis/util/PropertyToObjectUtils.java | 64 ++
.../rocketmq/redis/test/common/ConfigTest.java | 107 ++
.../rocketmq/redis/test/common/OptionsTest.java | 34 +
.../test/connector/RedisSourceConnectorTest.java | 35 +
.../redis/test/connector/RedisSourceTaskTest.java | 150 +++
.../test/converter/RedisEntryConverterTest.java | 118 +++
.../test/converter/RedisPositionConverterTest.java | 51 +
.../redis/test/handler/RedisEventHandlerTest.java | 468 +++++++++
.../rocketmq/redis/test/parser/ParserTest.java | 1108 ++++++++++++++++++++
.../apache/rocketmq/redis/test/pojo/GeoTest.java | 19 +
.../rocketmq/redis/test/pojo/KVEntryTest.java | 85 ++
.../rocketmq/redis/test/pojo/RedisEventTest.java | 33 +
.../redis/test/processor/ListenerTest.java | 135 +++
.../redis/test/processor/ProcessorTest.java | 193 ++++
.../redis/test/util/ParseStringUtilsTest.java | 45 +
.../redis/test/util/PropertyToObjectUtilsTest.java | 118 +++
.../style/copyright/Apache.xml | 23 +
.../style}/copyright/profiles_settings.xml | 4 +-
.../style}/rmq_checkstyle.xml | 7 -
.../style}/rmq_codeStyle.xml | 2 +-
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 | 20 +-
.../rocketmq/replicator/RmqMetaReplicator.java | 254 +++++
.../rocketmq/replicator/RmqSourceReplicator.java | 333 ++++++
.../apache/rocketmq/replicator/RmqSourceTask.java | 273 +++++
.../rocketmq/replicator/common/ConstDefine.java | 15 +-
.../apache/rocketmq/replicator/common/Utils.java | 203 ++++
.../rocketmq/replicator/config/ConfigDefine.java | 68 ++
.../rocketmq/replicator/config/ConfigUtil.java | 14 +-
.../rocketmq/replicator/config/DataType.java | 20 +-
.../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 | 32 +-
.../rocketmq/replicator/offset/OffsetSync.java | 75 ++
.../replicator/offset/OffsetSyncStore.java | 90 ++
.../rocketmq/replicator/schema/FieldName.java | 20 +-
.../replicator/strategy/DivideStrategyEnum.java | 17 +-
.../strategy/DivideTaskByConsistentHash.java | 89 ++
.../replicator/strategy/DivideTaskByQueue.java | 65 ++
.../replicator/strategy/DivideTaskByTopic.java | 60 ++
.../replicator/strategy/TaskDivideStrategy.java | 34 +-
.../replicator/RmqSourceReplicatorTest.java | 66 ++
321 files changed, 22950 insertions(+), 3138 deletions(-)
create mode 100644 connectors/rocketmq-connect-activemq/README-CN.md
create mode 100644 connectors/rocketmq-connect-activemq/README.md
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-activemq}/pom.xml (62%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java (52%)
create mode 100644 connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
create mode 100644 connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java => connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java (72%)
create mode 100644 connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
create mode 100644 connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
create mode 100644 connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
create mode 100644 connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
create mode 100644 connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
create mode 100644 connectors/rocketmq-connect-cassandra/README.md
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-cassandra}/pom.xml (60%)
create mode 100644 connectors/rocketmq-connect-cassandra/scripts/gen_data.py
create mode 100644 connectors/rocketmq-connect-cassandra/scripts/requirements.txt
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java (66%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java (66%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java (79%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java
copy rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/Config.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java (60%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java (54%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java (67%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java (67%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java (59%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java (67%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java (63%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java (66%)
create mode 100644 connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java (66%)
create mode 100644 connectors/rocketmq-connect-hudi/README.md
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-hudi}/pom.xml (55%)
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java (79%)
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java (68%)
create mode 100644 connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/LoggerName.java => connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java (80%)
copy {style => connectors/rocketmq-connect-hudi/style}/rmq_checkstyle.xml (95%)
create mode 100644 connectors/rocketmq-connect-jdbc/README.md
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-jdbc}/pom.xml (58%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java (66%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java (67%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java (66%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java (60%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java (55%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java (67%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java (59%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java (67%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java (63%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java (66%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java
create mode 100644 connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java (67%)
create mode 100644 connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-jms}/pom.xml (62%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java (54%)
create mode 100644 connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
create mode 100644 connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java => connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java (73%)
create mode 100644 connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
create mode 100644 connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
create mode 100644 connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
create mode 100644 connectors/rocketmq-connect-kafka/README.md
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-kafka}/pom.xml (66%)
create mode 100644 connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java (90%)
create mode 100644 connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
create mode 100644 connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
copy rocketmq-connect-cli/connectAdmin => connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties (65%)
create mode 100644 connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java (53%)
create mode 100644 connectors/rocketmq-connect-mongo/README.md
copy {rocketmq-connect-cli => connectors/rocketmq-connect-mongo}/pom.xml (72%)
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java => connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java (58%)
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java (56%)
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
create mode 100644 connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
create mode 100644 connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
create mode 100644 connectors/rocketmq-connect-rabbitmq/README.md
create mode 100644 connectors/rocketmq-connect-rabbitmq/pom.xml
create mode 100644 connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
create mode 100644 connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java (65%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java (55%)
create mode 100644 connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java (66%)
create mode 100644 connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
create mode 100644 connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java (52%)
create mode 100644 connectors/rocketmq-connect-redis/README-CN.md
create mode 100644 connectors/rocketmq-connect-redis/README.md
copy {rocketmq-connect-runtime => connectors/rocketmq-connect-redis}/pom.xml (63%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java (60%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java (67%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java (66%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java (55%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java (68%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java (53%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java (61%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java (61%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java (58%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java (54%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java (68%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java (57%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java (55%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java (62%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java (62%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java (61%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java (57%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java (61%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java (62%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java (58%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java (56%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java (66%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java (62%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java (62%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java (63%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java (50%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java (68%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java (55%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java (64%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java (62%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java (50%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java (57%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java (62%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java (63%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java (52%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java (55%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java (56%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java (59%)
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java (59%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java (51%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java (57%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java (55%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java (66%)
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
create mode 100644 connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
create mode 100644 connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
create mode 100644 connectors/rocketmq-connect-redis/style/copyright/Apache.xml
copy {style => connectors/rocketmq-connect-redis/style}/copyright/profiles_settings.xml (95%)
copy {style => connectors/rocketmq-connect-redis/style}/rmq_checkstyle.xml (95%)
copy {style => connectors/rocketmq-connect-redis/style}/rmq_codeStyle.xml (99%)
create mode 100644 connectors/rocketmq-replicator/.gitignore
create mode 100644 connectors/rocketmq-replicator/README.md
create mode 100644 connectors/rocketmq-replicator/package.xml
create mode 100644 connectors/rocketmq-replicator/pom.xml
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqConstants.java (55%)
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/ConstDefine.java (66%)
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigDefine.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigUtil.java (90%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/DataType.java (66%)
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfigEnum.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java (61%)
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSyncStore.java
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/FieldName.java (67%)
copy rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideStrategyEnum.java (66%)
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByConsistentHash.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java
create mode 100644 connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByTopic.java
copy rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java => connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/TaskDivideStrategy.java (68%)
create mode 100644 connectors/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/RmqSourceReplicatorTest.java
[rocketmq-connect] 04/10: Add 'connectors/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'
Posted by zh...@apache.org.
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 8ad07046d7eb4516d8f01dd994de33a18cac3826
Merge: cbb84d7 37a4db7
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:14 2022 +0800
Add 'connectors/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'
git-subtree-dir: connectors/rocketmq-connect-jms
git-subtree-mainline: cbb84d72cfe01e18de40aaf107e5da49847f567b
git-subtree-split: 37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d
connectors/rocketmq-connect-jms/pom.xml | 196 +++++++++++++++++++++
.../org/apache/rocketmq/connect/jms/Config.java | 163 +++++++++++++++++
.../org/apache/rocketmq/connect/jms/ErrorCode.java | 8 +
.../apache/rocketmq/connect/jms/Replicator.java | 67 +++++++
.../jms/connector/BaseJmsSourceConnector.java | 71 ++++++++
.../connect/jms/connector/BaseJmsSourceTask.java | 150 ++++++++++++++++
.../connect/jms/pattern/PatternProcessor.java | 90 ++++++++++
.../jms/connector/BaseJmsSourceConnectorTest.java | 82 +++++++++
8 files changed, 827 insertions(+)
diff --cc connectors/rocketmq-connect-jms/pom.xml
index 0000000,50e0490..50e0490
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/pom.xml
+++ b/connectors/rocketmq-connect-jms/pom.xml
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
index 0000000,1e69f89..1e69f89
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
index 0000000,b6dafb1..b6dafb1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
index 0000000,3e859a4..3e859a4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
index 0000000,68f7677..68f7677
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
index 0000000,7b1f7c4..7b1f7c4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
diff --cc connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
index 0000000,5399045..5399045
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
+++ b/connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
diff --cc connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
index 0000000,632c9d3..632c9d3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
[rocketmq-connect] 05/10: Add 'connectors/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
Posted by zh...@apache.org.
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 e2861dcabff7a8be4a227e414a6265f289514133
Merge: 8ad0704 59ac9fd
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:15 2022 +0800
Add 'connectors/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
git-subtree-dir: connectors/rocketmq-connect-kafka
git-subtree-mainline: 8ad07046d7eb4516d8f01dd994de33a18cac3826
git-subtree-split: 59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7
connectors/rocketmq-connect-kafka/README.md | 30 +++
connectors/rocketmq-connect-kafka/pom.xml | 205 +++++++++++++++++
.../connect/kafka/config/ConfigDefine.java | 67 ++++++
.../rocketmq/connect/kafka/config/ConfigUtil.java | 70 ++++++
.../kafka/connector/KafkaSourceConnector.java | 104 +++++++++
.../connect/kafka/connector/KafkaSourceTask.java | 250 +++++++++++++++++++++
.../main/resources/connect-kafka-source.properties | 22 ++
.../kafka/connector/KafkaSourceConnectorTest.java | 57 +++++
.../kafka/connector/KafkaSourceTaskTest.java | 43 ++++
9 files changed, 848 insertions(+)
diff --cc connectors/rocketmq-connect-kafka/README.md
index 0000000,213c8fa..213c8fa
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/README.md
+++ b/connectors/rocketmq-connect-kafka/README.md
diff --cc connectors/rocketmq-connect-kafka/pom.xml
index 0000000,ccc4cc1..ccc4cc1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/pom.xml
+++ b/connectors/rocketmq-connect-kafka/pom.xml
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
index 0000000,9a7f1ba..9a7f1ba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
index 0000000,0587dae..0587dae
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
index 0000000,680df6e..680df6e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
diff --cc connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
index 0000000,f077ac0..f077ac0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
+++ b/connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
diff --cc connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
index 0000000,5ab36ed..5ab36ed
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
+++ b/connectors/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
diff --cc connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
index 0000000,1e12ca3..1e12ca3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
index 0000000,57239f6..57239f6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
+++ b/connectors/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
[rocketmq-connect] 01/10: Add 'connectors/rocketmq-connect-cassandra/' from commit 'e2cc843ef4926a98797ca76880579941d5363fc6'
Posted by zh...@apache.org.
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 796adf1d99ffec8839136d3a8dc47440c069d2ef
Merge: a1e5f60 e2cc843
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:08 2022 +0800
Add 'connectors/rocketmq-connect-cassandra/' from commit 'e2cc843ef4926a98797ca76880579941d5363fc6'
git-subtree-dir: connectors/rocketmq-connect-cassandra
git-subtree-mainline: a1e5f6084d893257cbe861e9ee8d25894200bb7d
git-subtree-split: e2cc843ef4926a98797ca76880579941d5363fc6
connectors/rocketmq-connect-cassandra/README.md | 97 +++++++
connectors/rocketmq-connect-cassandra/pom.xml | 276 ++++++++++++++++++++
.../rocketmq-connect-cassandra/scripts/gen_data.py | 155 +++++++++++
.../scripts/requirements.txt | 2 +
.../connect/cassandra/common/CloneUtils.java | 44 ++++
.../connect/cassandra/common/ConstDefine.java | 23 ++
.../rocketmq/connect/cassandra/common/DBUtils.java | 91 +++++++
.../connect/cassandra/common/DataType.java | 26 ++
.../rocketmq/connect/cassandra/common/Utils.java | 76 ++++++
.../rocketmq/connect/cassandra/config/Config.java | 282 +++++++++++++++++++++
.../connect/cassandra/config/ConfigUtil.java | 70 +++++
.../cassandra/config/DbConnectorConfig.java | 110 ++++++++
.../cassandra/config/SinkDbConnectorConfig.java | 112 ++++++++
.../cassandra/config/SourceDbConnectorConfig.java | 87 +++++++
.../connect/cassandra/config/TaskDivideConfig.java | 123 +++++++++
.../connect/cassandra/config/TaskTopicInfo.java | 40 +++
.../connector/CassandraSinkConnector.java | 240 ++++++++++++++++++
.../cassandra/connector/CassandraSinkTask.java | 161 ++++++++++++
.../connector/CassandraSourceConnector.java | 108 ++++++++
.../cassandra/connector/CassandraSourceTask.java | 168 ++++++++++++
.../connect/cassandra/schema/Database.java | 140 ++++++++++
.../rocketmq/connect/cassandra/schema/Schema.java | 146 +++++++++++
.../rocketmq/connect/cassandra/schema/Table.java | 103 ++++++++
.../schema/column/BigIntColumnParser.java | 50 ++++
.../schema/column/BooleanColumnParser.java | 34 +++
.../cassandra/schema/column/ColumnParser.java | 118 +++++++++
.../schema/column/DateTimeColumnParser.java | 53 ++++
.../schema/column/DefaultColumnParser.java | 37 +++
.../cassandra/schema/column/EnumColumnParser.java | 46 ++++
.../cassandra/schema/column/IntColumnParser.java | 66 +++++
.../cassandra/schema/column/SetColumnParser.java | 54 ++++
.../schema/column/StringColumnParser.java | 57 +++++
.../cassandra/schema/column/TimeColumnParser.java | 39 +++
.../cassandra/schema/column/YearColumnParser.java | 40 +++
.../rocketmq/connect/cassandra/sink/Updater.java | 216 ++++++++++++++++
.../rocketmq/connect/cassandra/source/Querier.java | 164 ++++++++++++
.../cassandra/strategy/DivideStrategyEnum.java | 23 ++
.../cassandra/strategy/DivideTaskByTopic.java | 110 ++++++++
.../cassandra/strategy/TaskDivideStrategy.java | 32 +++
39 files changed, 3819 insertions(+)
diff --cc connectors/rocketmq-connect-cassandra/README.md
index 0000000,6439269..6439269
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/README.md
+++ b/connectors/rocketmq-connect-cassandra/README.md
diff --cc connectors/rocketmq-connect-cassandra/pom.xml
index 0000000,286a6ef..286a6ef
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/pom.xml
+++ b/connectors/rocketmq-connect-cassandra/pom.xml
diff --cc connectors/rocketmq-connect-cassandra/scripts/gen_data.py
index 0000000,8fde504..8fde504
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/scripts/gen_data.py
+++ b/connectors/rocketmq-connect-cassandra/scripts/gen_data.py
diff --cc connectors/rocketmq-connect-cassandra/scripts/requirements.txt
index 0000000,fc7dc31..fc7dc31
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/scripts/requirements.txt
+++ b/connectors/rocketmq-connect-cassandra/scripts/requirements.txt
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java
index 0000000,c860750..c860750
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java
index 0000000,462add2..462add2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java
index 0000000,bd58eea..bd58eea
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java
index 0000000,d6f814f..d6f814f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java
index 0000000,0911e20..0911e20
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java
index 0000000,b9b115e..b9b115e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java
index 0000000,1c08fb2..1c08fb2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java
index 0000000,3dd25c0..3dd25c0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java
index 0000000,3145033..3145033
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java
index 0000000,6a3f685..6a3f685
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java
index 0000000,7c43137..7c43137
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java
index 0000000,074faab..074faab
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java
index 0000000,6ce23f6..6ce23f6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java
index 0000000,a8e9b0a..a8e9b0a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java
index 0000000,a8adc74..a8adc74
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java
index 0000000,cac44ed..cac44ed
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java
index 0000000,c8f69e6..c8f69e6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java
index 0000000,01054e0..01054e0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java
index 0000000,902b797..902b797
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java
index 0000000,0506469..0506469
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
index 0000000,8d5b2bb..8d5b2bb
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java
index 0000000,1eab587..1eab587
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java
index 0000000,b110a19..b110a19
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
index 0000000,01d8d1a..01d8d1a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java
index 0000000,245dfd6..245dfd6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java
index 0000000,2257682..2257682
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
index 0000000,eaa6dad..eaa6dad
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java
index 0000000,2bd7a36..2bd7a36
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
index 0000000,c812a53..c812a53
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java
index 0000000,82d61a8..82d61a8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java
index 0000000,1c3f2c1..1c3f2c1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java
index 0000000,8a8ddf4..8a8ddf4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
index 0000000,f0eac2b..f0eac2b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java
index 0000000,68395d3..68395d3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java
diff --cc connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java
index 0000000,70a6773..70a6773
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java
+++ b/connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java
[rocketmq-connect] 02/10: Add 'connectors/rocketmq-connect-hudi/' from commit '5da4b78705108ac6d260283cd38f9be08d2590b9'
Posted by zh...@apache.org.
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 11d2b68ab1e5660aeb09ca972c390f45132bbd6b
Merge: 796adf1 5da4b78
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:10 2022 +0800
Add 'connectors/rocketmq-connect-hudi/' from commit '5da4b78705108ac6d260283cd38f9be08d2590b9'
git-subtree-dir: connectors/rocketmq-connect-hudi
git-subtree-mainline: 796adf1d99ffec8839136d3a8dc47440c069d2ef
git-subtree-split: 5da4b78705108ac6d260283cd38f9be08d2590b9
connectors/rocketmq-connect-hudi/README.md | 77 ++++++
connectors/rocketmq-connect-hudi/pom.xml | 287 +++++++++++++++++++++
.../rocketmq/connect/hudi/config/CloneUtils.java | 50 ++++
.../rocketmq/connect/hudi/config/ConfigUtil.java | 70 +++++
.../connect/hudi/config/HudiConnectConfig.java | 173 +++++++++++++
.../connect/hudi/config/SinkConnectConfig.java | 139 ++++++++++
.../apache/rocketmq/connect/hudi/config/Utils.java | 75 ++++++
.../connect/hudi/connector/HudiSinkConnector.java | 250 ++++++++++++++++++
.../connect/hudi/connector/HudiSinkTask.java | 111 ++++++++
.../apache/rocketmq/connect/hudi/sink/Updater.java | 239 +++++++++++++++++
.../connect/hudi/strategy/ITaskDivideStrategy.java | 27 ++
.../hudi/strategy/TaskDivideByQueueStrategy.java | 80 ++++++
.../hudi/strategy/TaskDivideStrategyFactory.java | 25 ++
.../rocketmq-connect-hudi/style/rmq_checkstyle.xml | 135 ++++++++++
14 files changed, 1738 insertions(+)
diff --cc connectors/rocketmq-connect-hudi/README.md
index 0000000,cadc364..cadc364
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/README.md
+++ b/connectors/rocketmq-connect-hudi/README.md
diff --cc connectors/rocketmq-connect-hudi/pom.xml
index 0000000,97c8785..97c8785
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/pom.xml
+++ b/connectors/rocketmq-connect-hudi/pom.xml
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
index 0000000,dc3605d..dc3605d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
index 0000000,88f8a8e..88f8a8e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
index 0000000,4c04605..4c04605
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
index 0000000,943df40..943df40
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
index 0000000,d9bc6fe..d9bc6fe
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
index 0000000,a496418..a496418
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
index 0000000,b01c660..b01c660
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
index 0000000,8e7e288..8e7e288
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
index 0000000,a91c066..a91c066
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
index 0000000,c68e17c..c68e17c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
diff --cc connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
index 0000000,1d693a8..1d693a8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
+++ b/connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
diff --cc connectors/rocketmq-connect-hudi/style/rmq_checkstyle.xml
index 0000000,776b305..776b305
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-hudi/style/rmq_checkstyle.xml
+++ b/connectors/rocketmq-connect-hudi/style/rmq_checkstyle.xml
[rocketmq-connect] 09/10: Add 'connectors/rocketmq-replicator/' from commit '55631bb1fe4d3864c2d45dc7fee9e49764d7b3ac'
Posted by zh...@apache.org.
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
[rocketmq-connect] 08/10: Add 'connectors/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
Posted by zh...@apache.org.
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 fb6e0852880c6b37fe734b8a8048379e1489456a
Merge: 3f900aa 4fdd8b2
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:21 2022 +0800
Add 'connectors/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
git-subtree-dir: connectors/rocketmq-connect-redis
git-subtree-mainline: 3f900aab003d00885c97adfbbf8fb3aa9f8e3835
git-subtree-split: 4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02
connectors/rocketmq-connect-redis/README-CN.md | 19 +
connectors/rocketmq-connect-redis/README.md | 19 +
connectors/rocketmq-connect-redis/pom.xml | 208 ++++
.../rocketmq/connect/redis/common/Config.java | 237 +++++
.../rocketmq/connect/redis/common/Options.java | 124 +++
.../connect/redis/common/RedisConstants.java | 46 +
.../rocketmq/connect/redis/common/SyncMod.java | 37 +
.../redis/connector/RedisSourceConnector.java | 70 ++
.../connect/redis/connector/RedisSourceTask.java | 148 +++
.../connect/redis/converter/KVEntryConverter.java | 28 +
.../redis/converter/RedisEntryConverter.java | 134 +++
.../redis/converter/RedisPositionConverter.java | 54 +
.../redis/handler/DefaultRedisEventHandler.java | 174 +++
.../connect/redis/handler/RedisEventHandler.java | 72 ++
.../redis/parser/AbstractCommandParser.java | 82 ++
.../connect/redis/parser/AppendParser.java | 38 +
.../connect/redis/parser/BitFieldParser.java | 32 +
.../rocketmq/connect/redis/parser/BitOpParser.java | 41 +
.../connect/redis/parser/BrPopLPushParser.java | 41 +
.../connect/redis/parser/CommonParser.java | 117 +++
.../connect/redis/parser/DecrByParser.java | 38 +
.../rocketmq/connect/redis/parser/DecrParser.java | 32 +
.../redis/parser/DefaultRedisRdbParser.java | 197 ++++
.../rocketmq/connect/redis/parser/DelParser.java | 46 +
.../rocketmq/connect/redis/parser/EvalParser.java | 38 +
.../connect/redis/parser/EvalShaParser.java | 38 +
.../rocketmq/connect/redis/parser/ExecParser.java | 32 +
.../connect/redis/parser/ExpireAtParser.java | 38 +
.../connect/redis/parser/ExpireParser.java | 40 +
.../connect/redis/parser/FlushAllParser.java | 32 +
.../connect/redis/parser/FlushDbParser.java | 33 +
.../connect/redis/parser/GeoAddParser.java | 49 +
.../connect/redis/parser/GetsetParser.java | 37 +
.../rocketmq/connect/redis/parser/HDelParser.java | 41 +
.../connect/redis/parser/HIncrByParser.java | 41 +
.../connect/redis/parser/HSetNxParser.java | 37 +
.../rocketmq/connect/redis/parser/HSetParser.java | 37 +
.../rocketmq/connect/redis/parser/HmSetParser.java | 37 +
.../connect/redis/parser/IncrByParser.java | 38 +
.../rocketmq/connect/redis/parser/IncrParser.java | 32 +
.../rocketmq/connect/redis/parser/LPopParser.java | 32 +
.../rocketmq/connect/redis/parser/LPushParser.java | 41 +
.../connect/redis/parser/LPushXParser.java | 37 +
.../rocketmq/connect/redis/parser/LRemParser.java | 41 +
.../rocketmq/connect/redis/parser/LSetParser.java | 41 +
.../rocketmq/connect/redis/parser/LTrimParser.java | 41 +
.../connect/redis/parser/LinsertParser.java | 51 +
.../connect/redis/parser/MSetNxParser.java | 37 +
.../rocketmq/connect/redis/parser/MSetParser.java | 37 +
.../rocketmq/connect/redis/parser/MoveParser.java | 38 +
.../rocketmq/connect/redis/parser/MultiParser.java | 32 +
.../connect/redis/parser/PExpireAtParser.java | 38 +
.../connect/redis/parser/PExpireParser.java | 38 +
.../connect/redis/parser/PSetExParser.java | 41 +
.../rocketmq/connect/redis/parser/Parser.java | 24 +
.../connect/redis/parser/PersistParser.java | 32 +
.../rocketmq/connect/redis/parser/PfAddParser.java | 41 +
.../connect/redis/parser/PfCountParser.java | 37 +
.../connect/redis/parser/PfMergeParser.java | 41 +
.../connect/redis/parser/PublishParser.java | 37 +
.../connect/redis/parser/RPopLPushParser.java | 37 +
.../rocketmq/connect/redis/parser/RPopParser.java | 32 +
.../rocketmq/connect/redis/parser/RPushParser.java | 41 +
.../connect/redis/parser/RPushXParser.java | 37 +
.../connect/redis/parser/RedisRdbParser.java | 67 ++
.../connect/redis/parser/RenameNxParser.java | 37 +
.../connect/redis/parser/RenameParser.java | 37 +
.../connect/redis/parser/RestoreParser.java | 45 +
.../rocketmq/connect/redis/parser/SAddParser.java | 41 +
.../connect/redis/parser/SDiffStoreParser.java | 41 +
.../connect/redis/parser/SInterStoreParser.java | 41 +
.../rocketmq/connect/redis/parser/SMoveParser.java | 41 +
.../rocketmq/connect/redis/parser/SRemParser.java | 41 +
.../connect/redis/parser/SUnionStoreParser.java | 41 +
.../connect/redis/parser/ScriptParser.java | 32 +
.../connect/redis/parser/SelectParser.java | 38 +
.../connect/redis/parser/SetBitParser.java | 41 +
.../rocketmq/connect/redis/parser/SetExParser.java | 42 +
.../rocketmq/connect/redis/parser/SetNxParser.java | 37 +
.../rocketmq/connect/redis/parser/SetParser.java | 59 ++
.../connect/redis/parser/SetRangeParser.java | 41 +
.../rocketmq/connect/redis/parser/SortParser.java | 32 +
.../connect/redis/parser/SwapDbParser.java | 38 +
.../connect/redis/parser/UnLinkParser.java | 37 +
.../rocketmq/connect/redis/parser/XAckParser.java | 49 +
.../rocketmq/connect/redis/parser/XAddParser.java | 46 +
.../connect/redis/parser/XClaimParser.java | 88 ++
.../rocketmq/connect/redis/parser/XDelParser.java | 41 +
.../connect/redis/parser/XGroupParser.java | 32 +
.../connect/redis/parser/XSetIdParser.java | 37 +
.../rocketmq/connect/redis/parser/XTrimParser.java | 43 +
.../rocketmq/connect/redis/parser/ZAddParser.java | 69 ++
.../connect/redis/parser/ZIncrByParser.java | 41 +
.../connect/redis/parser/ZInterStoreParser.java | 37 +
.../connect/redis/parser/ZPopMaxParser.java | 38 +
.../connect/redis/parser/ZPopMinParser.java | 38 +
.../rocketmq/connect/redis/parser/ZRemParser.java | 41 +
.../connect/redis/parser/ZRemRangeByLexParser.java | 41 +
.../redis/parser/ZRemRangeByRankParser.java | 41 +
.../redis/parser/ZRemRangeByScoreParser.java | 41 +
.../connect/redis/parser/ZUnionStoreParser.java | 37 +
.../apache/rocketmq/connect/redis/pojo/Geo.java | 48 +
.../rocketmq/connect/redis/pojo/KVEntry.java | 71 ++
.../rocketmq/connect/redis/pojo/RedisEntry.java | 171 +++
.../rocketmq/connect/redis/pojo/RedisEvent.java | 59 ++
.../processor/DefaultRedisEventProcessor.java | 453 ++++++++
.../redis/processor/RedisClosedListener.java | 37 +
.../redis/processor/RedisEventListener.java | 121 +++
.../redis/processor/RedisEventProcessor.java | 40 +
.../processor/RedisEventProcessorCallback.java | 23 +
.../redis/processor/RedisExceptionListener.java | 44 +
.../connect/redis/util/ParseStringUtils.java | 54 +
.../connect/redis/util/PropertyToObjectUtils.java | 64 ++
.../rocketmq/redis/test/common/ConfigTest.java | 107 ++
.../rocketmq/redis/test/common/OptionsTest.java | 34 +
.../test/connector/RedisSourceConnectorTest.java | 35 +
.../redis/test/connector/RedisSourceTaskTest.java | 150 +++
.../test/converter/RedisEntryConverterTest.java | 118 +++
.../test/converter/RedisPositionConverterTest.java | 51 +
.../redis/test/handler/RedisEventHandlerTest.java | 468 +++++++++
.../rocketmq/redis/test/parser/ParserTest.java | 1108 ++++++++++++++++++++
.../apache/rocketmq/redis/test/pojo/GeoTest.java | 19 +
.../rocketmq/redis/test/pojo/KVEntryTest.java | 85 ++
.../rocketmq/redis/test/pojo/RedisEventTest.java | 33 +
.../redis/test/processor/ListenerTest.java | 135 +++
.../redis/test/processor/ProcessorTest.java | 193 ++++
.../redis/test/util/ParseStringUtilsTest.java | 45 +
.../redis/test/util/PropertyToObjectUtilsTest.java | 118 +++
.../style/copyright/Apache.xml | 23 +
.../style/copyright/profiles_settings.xml | 64 ++
.../style/rmq_checkstyle.xml | 134 +++
.../rocketmq-connect-redis/style/rmq_codeStyle.xml | 143 +++
132 files changed, 9375 insertions(+)
diff --cc connectors/rocketmq-connect-redis/README-CN.md
index 0000000,786b0d6..786b0d6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/README-CN.md
+++ b/connectors/rocketmq-connect-redis/README-CN.md
diff --cc connectors/rocketmq-connect-redis/README.md
index 0000000,6da01d7..6da01d7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/README.md
+++ b/connectors/rocketmq-connect-redis/README.md
diff --cc connectors/rocketmq-connect-redis/pom.xml
index 0000000,62f7950..62f7950
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/pom.xml
+++ b/connectors/rocketmq-connect-redis/pom.xml
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
index 0000000,fe41075..fe41075
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
index 0000000,71cc07f..71cc07f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
index 0000000,fd01c13..fd01c13
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
index 0000000,9ad2093..9ad2093
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
index 0000000,fde9f92..fde9f92
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
index 0000000,1b97836..1b97836
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
index 0000000,de1b8ca..de1b8ca
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
index 0000000,23de075..23de075
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
index 0000000,37e9e98..37e9e98
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
index 0000000,14362b9..14362b9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
index 0000000,6f93b2d..6f93b2d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
index 0000000,bf67b7d..bf67b7d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
index 0000000,67c5a76..67c5a76
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
index 0000000,55c7ce0..55c7ce0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
index 0000000,38b1b71..38b1b71
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
index 0000000,bd8a090..bd8a090
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
index 0000000,f8dca37..f8dca37
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
index 0000000,edfad48..edfad48
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
index 0000000,c632603..c632603
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
index 0000000,9a4c3ad..9a4c3ad
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
index 0000000,17ae917..17ae917
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
index 0000000,deb36c1..deb36c1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
index 0000000,38b564e..38b564e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
index 0000000,0b48a59..0b48a59
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
index 0000000,e04606c..e04606c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
index 0000000,7a47de7..7a47de7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
index 0000000,7db9603..7db9603
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
index 0000000,908d456..908d456
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
index 0000000,7136787..7136787
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
index 0000000,1c816fc..1c816fc
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
index 0000000,9b17875..9b17875
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
index 0000000,7547740..7547740
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
index 0000000,02268d0..02268d0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
index 0000000,87dcc33..87dcc33
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
index 0000000,4e317e4..4e317e4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
index 0000000,d691955..d691955
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
index 0000000,db0402b..db0402b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
index 0000000,cc92668..cc92668
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
index 0000000,68672cf..68672cf
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
index 0000000,bc301a5..bc301a5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
index 0000000,6716061..6716061
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
index 0000000,be6fed4..be6fed4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
index 0000000,39a4386..39a4386
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
index 0000000,c3d65b6..c3d65b6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
index 0000000,8b13652..8b13652
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
index 0000000,34f9f11..34f9f11
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
index 0000000,0173086..0173086
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
index 0000000,cd32b16..cd32b16
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
index 0000000,0390de0..0390de0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
index 0000000,efeee21..efeee21
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
index 0000000,7ed476e..7ed476e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
index 0000000,b9a4b12..b9a4b12
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
index 0000000,6bfb2d0..6bfb2d0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
index 0000000,51cfda2..51cfda2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
index 0000000,fe674d9..fe674d9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
index 0000000,650c75b..650c75b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
index 0000000,0d5d235..0d5d235
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
index 0000000,38edce3..38edce3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
index 0000000,85f122a..85f122a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
index 0000000,8824d0b..8824d0b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
index 0000000,de2d21b..de2d21b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
index 0000000,fa4e46a..fa4e46a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
index 0000000,14f4c4f..14f4c4f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
index 0000000,9de8fe3..9de8fe3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
index 0000000,53a4569..53a4569
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
index 0000000,bb89eff..bb89eff
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
index 0000000,dc5ca3e..dc5ca3e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
index 0000000,be52db7..be52db7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
index 0000000,62007bb..62007bb
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
index 0000000,f51ad00..f51ad00
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
index 0000000,d821aba..d821aba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
index 0000000,746edb2..746edb2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
index 0000000,a6ba72f..a6ba72f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
index 0000000,b7b9495..b7b9495
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
index 0000000,4c41260..4c41260
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
index 0000000,ba784b0..ba784b0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
index 0000000,c0afe71..c0afe71
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
index 0000000,61b3c39..61b3c39
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
index 0000000,0888917..0888917
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
index 0000000,27d7a33..27d7a33
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
index 0000000,6ee98ce..6ee98ce
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
index 0000000,7c2e2c9..7c2e2c9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
index 0000000,755c267..755c267
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
index 0000000,d3a2aa0..d3a2aa0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
index 0000000,f1dcefa..f1dcefa
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
index 0000000,5495270..5495270
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
index 0000000,2af95c3..2af95c3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
index 0000000,86a85b6..86a85b6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
index 0000000,555aaf5..555aaf5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
index 0000000,6bbf0d5..6bbf0d5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
index 0000000,9c8382e..9c8382e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
index 0000000,d4b4ff0..d4b4ff0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
index 0000000,070d2da..070d2da
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
index 0000000,775a646..775a646
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
index 0000000,cbdaf91..cbdaf91
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
index 0000000,3827a41..3827a41
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
index 0000000,8693382..8693382
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
index 0000000,04c0ef4..04c0ef4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
index 0000000,cf539db..cf539db
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
index 0000000,ff8cb29..ff8cb29
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
index 0000000,5cf2d86..5cf2d86
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
index 0000000,585df47..585df47
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
index 0000000,cde4367..cde4367
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
index 0000000,8a47fd8..8a47fd8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
index 0000000,57d5aa8..57d5aa8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
index 0000000,bdab382..bdab382
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
index 0000000,c44f460..c44f460
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
index 0000000,bdbd139..bdbd139
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
index 0000000,b4714e5..b4714e5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
index 0000000,62f09ce..62f09ce
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
index 0000000,e63f45f..e63f45f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
index 0000000,a7ac8ae..a7ac8ae
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
index 0000000,355351b..355351b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
index 0000000,4dd4397..4dd4397
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
index 0000000,9b4d91c..9b4d91c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
index 0000000,03986d2..03986d2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
index 0000000,068187f..068187f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
index 0000000,b2b7960..b2b7960
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
index 0000000,c905140..c905140
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
index 0000000,65d8bcf..65d8bcf
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
index 0000000,a412e6d..a412e6d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
index 0000000,6500eba..6500eba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
index 0000000,1410b2a..1410b2a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
index 0000000,2a67959..2a67959
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
index 0000000,ddcc59b..ddcc59b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
diff --cc connectors/rocketmq-connect-redis/style/copyright/Apache.xml
index 0000000,e3e3dec..e3e3dec
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/copyright/Apache.xml
+++ b/connectors/rocketmq-connect-redis/style/copyright/Apache.xml
diff --cc connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml
index 0000000,747c7e2..747c7e2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml
+++ b/connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml
diff --cc connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml
index 0000000,2872eb7..2872eb7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml
+++ b/connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml
diff --cc connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml
index 0000000,7c7ce54..7c7ce54
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml
+++ b/connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml
[rocketmq-connect] 03/10: Add 'connectors/rocketmq-connect-jdbc/' from commit '6708ada617d9f6cfef5ca42a3c2f97af44603a89'
Posted by zh...@apache.org.
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 cbb84d72cfe01e18de40aaf107e5da49847f567b
Merge: 11d2b68 6708ada
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:12 2022 +0800
Add 'connectors/rocketmq-connect-jdbc/' from commit '6708ada617d9f6cfef5ca42a3c2f97af44603a89'
git-subtree-dir: connectors/rocketmq-connect-jdbc
git-subtree-mainline: 11d2b68ab1e5660aeb09ca972c390f45132bbd6b
git-subtree-split: 6708ada617d9f6cfef5ca42a3c2f97af44603a89
connectors/rocketmq-connect-jdbc/README.md | 85 +++++
connectors/rocketmq-connect-jdbc/pom.xml | 271 ++++++++++++++++
.../rocketmq/connect/jdbc/common/CloneUtils.java | 28 ++
.../rocketmq/connect/jdbc/common/ConstDefine.java | 23 ++
.../rocketmq/connect/jdbc/common/DBUtils.java | 212 ++++++++++++
.../apache/rocketmq/connect/jdbc/common/Utils.java | 74 +++++
.../rocketmq/connect/jdbc/config/Config.java | 357 +++++++++++++++++++++
.../rocketmq/connect/jdbc/config/ConfigUtil.java | 52 +++
.../rocketmq/connect/jdbc/config/DataType.java | 26 ++
.../connect/jdbc/config/DbConnectorConfig.java | 84 +++++
.../connect/jdbc/config/SinkDbConnectorConfig.java | 98 ++++++
.../jdbc/config/SourceDbConnectorConfig.java | 73 +++++
.../connect/jdbc/config/TaskDivideConfig.java | 112 +++++++
.../connect/jdbc/config/TaskTopicInfo.java | 37 +++
.../connect/jdbc/connector/JdbcSinkConnector.java | 221 +++++++++++++
.../connect/jdbc/connector/JdbcSinkTask.java | 134 ++++++++
.../jdbc/connector/JdbcSourceConnector.java | 105 ++++++
.../connect/jdbc/connector/JdbcSourceTask.java | 183 +++++++++++
.../rocketmq/connect/jdbc/schema/Database.java | 109 +++++++
.../rocketmq/connect/jdbc/schema/Schema.java | 123 +++++++
.../apache/rocketmq/connect/jdbc/schema/Table.java | 101 ++++++
.../jdbc/schema/column/BigIntColumnParser.java | 50 +++
.../connect/jdbc/schema/column/ColumnParser.java | 104 ++++++
.../jdbc/schema/column/DateTimeColumnParser.java | 53 +++
.../jdbc/schema/column/DefaultColumnParser.java | 37 +++
.../jdbc/schema/column/EnumColumnParser.java | 46 +++
.../jdbc/schema/column/IntColumnParser.java | 66 ++++
.../jdbc/schema/column/SetColumnParser.java | 54 ++++
.../jdbc/schema/column/StringColumnParser.java | 57 ++++
.../jdbc/schema/column/TimeColumnParser.java | 39 +++
.../jdbc/schema/column/YearColumnParser.java | 40 +++
.../apache/rocketmq/connect/jdbc/sink/Updater.java | 258 +++++++++++++++
.../rocketmq/connect/jdbc/source/Querier.java | 173 ++++++++++
.../jdbc/source/TimestampIncrementingQuerier.java | 311 ++++++++++++++++++
.../connect/jdbc/strategy/DivideStrategyEnum.java | 23 ++
.../connect/jdbc/strategy/DivideTaskByQueue.java | 72 +++++
.../connect/jdbc/strategy/DivideTaskByTopic.java | 113 +++++++
.../connect/jdbc/strategy/TaskDivideStrategy.java | 32 ++
.../jdbc/connector/JdbcSourceConnectorTest.java | 79 +++++
39 files changed, 4115 insertions(+)
diff --cc connectors/rocketmq-connect-jdbc/README.md
index 0000000,54c04ea..54c04ea
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/README.md
+++ b/connectors/rocketmq-connect-jdbc/README.md
diff --cc connectors/rocketmq-connect-jdbc/pom.xml
index 0000000,2feaa22..2feaa22
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/pom.xml
+++ b/connectors/rocketmq-connect-jdbc/pom.xml
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java
index 0000000,f0ff98e..f0ff98e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java
index 0000000,e6d2f7a..e6d2f7a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java
index 0000000,963fbf6..963fbf6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java
index 0000000,5708e34..5708e34
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
index 0000000,1a9bbc9..1a9bbc9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java
index 0000000,53563f2..53563f2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java
index 0000000,ef7408a..ef7408a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java
index 0000000,43bd165..43bd165
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java
index 0000000,26b1541..26b1541
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java
index 0000000,4972739..4972739
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java
index 0000000,8b15a2f..8b15a2f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java
index 0000000,5c2a21e..5c2a21e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java
index 0000000,53379ec..53379ec
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java
index 0000000,31f43e3..31f43e3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
index 0000000,ee62133..ee62133
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java
index 0000000,f36623f..f36623f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java
index 0000000,33a9a22..33a9a22
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
index 0000000,1cfaf2c..1cfaf2c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java
index 0000000,891fb9a..891fb9a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java
index 0000000,610f07d..610f07d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java
index 0000000,341064e..341064e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java
index 0000000,c9b39e3..c9b39e3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java
index 0000000,ee3075a..ee3075a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java
index 0000000,0fd14ba..0fd14ba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java
index 0000000,36c6078..36c6078
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java
index 0000000,d1e6bbc..d1e6bbc
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java
index 0000000,cd4f04f..cd4f04f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java
index 0000000,9926d81..9926d81
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java
index 0000000,14cc798..14cc798
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java
index 0000000,9feffe6..9feffe6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
index 0000000,03447a8..03447a8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java
index 0000000,0ab72df..0ab72df
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java
index 0000000,0afa470..0afa470
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java
index 0000000,9d23fd2..9d23fd2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java
index 0000000,5762795..5762795
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java
diff --cc connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java
index 0000000,736fcac..736fcac
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java
+++ b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java
diff --cc connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java
index 0000000,5d25f98..5d25f98
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java
[rocketmq-connect] 10/10: Add 'connectors/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
Posted by zh...@apache.org.
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 08fb7050d0a9709b07f722bbbaea601d2ac4c3b7
Merge: 0e15ffa e8aedf3
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:13:16 2022 +0800
Add 'connectors/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
git-subtree-dir: connectors/rocketmq-connect-activemq
git-subtree-mainline: 0e15ffa030cceae05ed4517289b2df09daa5fc48
git-subtree-split: e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f
connectors/rocketmq-connect-activemq/README-CN.md | 16 ++
connectors/rocketmq-connect-activemq/README.md | 16 ++
connectors/rocketmq-connect-activemq/pom.xml | 201 +++++++++++++++++++++
.../apache/rocketmq/connect/activemq/Config.java | 163 +++++++++++++++++
.../rocketmq/connect/activemq/ErrorCode.java | 8 +
.../rocketmq/connect/activemq/Replicator.java | 63 +++++++
.../connector/ActivemqSourceConnector.java | 72 ++++++++
.../activemq/connector/ActivemqSourceTask.java | 141 +++++++++++++++
.../connect/activemq/pattern/PatternProcessor.java | 89 +++++++++
.../rocketmq/connect/activemq/ReplicatorTest.java | 74 ++++++++
.../activemq/connector/ActivemqConnectorTest.java | 58 ++++++
.../activemq/connector/ActivemqSourceTaskTest.java | 165 +++++++++++++++++
12 files changed, 1066 insertions(+)
diff --cc connectors/rocketmq-connect-activemq/README-CN.md
index 0000000,be03683..be03683
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/README-CN.md
+++ b/connectors/rocketmq-connect-activemq/README-CN.md
diff --cc connectors/rocketmq-connect-activemq/README.md
index 0000000,e15149e..e15149e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/README.md
+++ b/connectors/rocketmq-connect-activemq/README.md
diff --cc connectors/rocketmq-connect-activemq/pom.xml
index 0000000,ccb4118..ccb4118
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/pom.xml
+++ b/connectors/rocketmq-connect-activemq/pom.xml
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
index 0000000,30f898d..30f898d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
index 0000000,de3b3f5..de3b3f5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
index 0000000,e0ebe12..e0ebe12
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
index 0000000,7e6290b..7e6290b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
index 0000000,c009274..c009274
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
diff --cc connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
index 0000000,6e39a7e..6e39a7e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
+++ b/connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
diff --cc connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
index 0000000,b94237e..b94237e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
+++ b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
diff --cc connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
index 0000000,22b301c..22b301c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
+++ b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
diff --cc connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
index 0000000,a71050c..a71050c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
+++ b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
[rocketmq-connect] 06/10: Add 'connectors/rocketmq-connect-mongo/' from commit 'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
Posted by zh...@apache.org.
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 d0bd4f085dce5a8bfa393e953ed14781ccb73e82
Merge: e2861dc b307466
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:17 2022 +0800
Add 'connectors/rocketmq-connect-mongo/' from commit 'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
git-subtree-dir: connectors/rocketmq-connect-mongo
git-subtree-mainline: e2861dcabff7a8be4a227e414a6265f289514133
git-subtree-split: b307466f3fc4fa25ba21de87c568a4095cf18f4f
connectors/rocketmq-connect-mongo/README.md | 43 ++++
connectors/rocketmq-connect-mongo/pom.xml | 180 ++++++++++++++
.../org/apache/connect/mongo/SourceTaskConfig.java | 266 +++++++++++++++++++++
.../mongo/connector/MongoSourceConnector.java | 76 ++++++
.../connect/mongo/connector/MongoSourceTask.java | 105 ++++++++
.../mongo/connector/builder/MongoDataEntry.java | 134 +++++++++++
.../connect/mongo/initsync/CollectionMeta.java | 58 +++++
.../apache/connect/mongo/initsync/InitSync.java | 163 +++++++++++++
.../apache/connect/mongo/replicator/Constants.java | 36 +++
.../mongo/replicator/MongoClientFactory.java | 129 ++++++++++
.../connect/mongo/replicator/OperationFilter.java | 80 +++++++
.../apache/connect/mongo/replicator/Position.java | 85 +++++++
.../connect/mongo/replicator/ReplicaSet.java | 112 +++++++++
.../connect/mongo/replicator/ReplicaSetConfig.java | 75 ++++++
.../mongo/replicator/ReplicaSetManager.java | 85 +++++++
.../mongo/replicator/ReplicaSetsContext.java | 121 ++++++++++
.../connect/mongo/replicator/ReplicatorTask.java | 128 ++++++++++
.../replicator/event/Document2EventConverter.java | 49 ++++
.../mongo/replicator/event/OperationType.java | 62 +++++
.../mongo/replicator/event/ReplicationEvent.java | 176 ++++++++++++++
.../java/org/apache/connect/mongo/FilterTest.java | 67 ++++++
.../org/apache/connect/mongo/MongoFactoryTest.java | 177 ++++++++++++++
.../connect/mongo/MongoSourceConnectorTest.java | 95 ++++++++
.../apache/connect/mongo/MongoSourceTaskTest.java | 142 +++++++++++
.../java/org/apache/connect/mongo/MongoTest.java | 138 +++++++++++
.../apache/connect/mongo/OperationTypeTest.java | 37 +++
.../apache/connect/mongo/ReplicaContextTest.java | 33 +++
.../connect/mongo/ReplicaSetManagerTest.java | 58 +++++
.../org/apache/connect/mongo/ReplicaSetTest.java | 59 +++++
29 files changed, 2969 insertions(+)
diff --cc connectors/rocketmq-connect-mongo/README.md
index 0000000,bec30a3..bec30a3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/README.md
+++ b/connectors/rocketmq-connect-mongo/README.md
diff --cc connectors/rocketmq-connect-mongo/pom.xml
index 0000000,5c412bf..5c412bf
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/pom.xml
+++ b/connectors/rocketmq-connect-mongo/pom.xml
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
index 0000000,d184b5c..d184b5c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
index 0000000,5be2e0d..5be2e0d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
index 0000000,49bcf49..49bcf49
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
index 0000000,1d6dfe5..1d6dfe5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
index 0000000,4af5060..4af5060
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
index 0000000,a51b727..a51b727
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
index 0000000,7ba1ac4..7ba1ac4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
index 0000000,11bca8f..11bca8f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
index 0000000,a173f6c..a173f6c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
index 0000000,29fd856..29fd856
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
index 0000000,8393316..8393316
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
index 0000000,ced90b8..ced90b8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
index 0000000,88097d8..88097d8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
index 0000000,8dd85d7..8dd85d7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
index 0000000,cd78f24..cd78f24
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
index 0000000,99ab707..99ab707
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
index 0000000,b418666..b418666
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
diff --cc connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
index 0000000,7adca71..7adca71
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
+++ b/connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
index 0000000,d5deefd..d5deefd
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
index 0000000,e47d2c4..e47d2c4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
index 0000000,cc02fbc..cc02fbc
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
index 0000000,4983a66..4983a66
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
index 0000000,3d900fa..3d900fa
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
index 0000000,d8c5a9b..d8c5a9b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
index 0000000,16cb959..16cb959
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
index 0000000,1d3b743..1d3b743
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
diff --cc connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
index 0000000,07eefae..07eefae
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
+++ b/connectors/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
[rocketmq-connect] 07/10: Add 'connectors/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
Posted by zh...@apache.org.
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 3f900aab003d00885c97adfbbf8fb3aa9f8e3835
Merge: d0bd4f0 a7ab1c4
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:19 2022 +0800
Add 'connectors/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
git-subtree-dir: connectors/rocketmq-connect-rabbitmq
git-subtree-mainline: d0bd4f085dce5a8bfa393e953ed14781ccb73e82
git-subtree-split: a7ab1c46a9938df2984c3ad730609c1a7797cc9b
connectors/rocketmq-connect-rabbitmq/README.md | 17 ++
connectors/rocketmq-connect-rabbitmq/pom.xml | 205 +++++++++++++++++++++
.../rocketmq/connect/rabbitmq/ErrorCode.java | 8 +
.../rocketmq/connect/rabbitmq/RabbitmqConfig.java | 61 ++++++
.../connector/RabbitmqSourceConnector.java | 35 ++++
.../rabbitmq/connector/RabbitmqSourceTask.java | 37 ++++
.../rabbitmq/pattern/RabbitMQPatternProcessor.java | 48 +++++
.../rocketmq/connect/jms/RabbitmqConfigTest.java | 28 +++
.../connector/RabbitmqSourceConnectorTest.java | 54 ++++++
.../rabbitmq/connector/RabbitmqSourceTaskTest.java | 164 +++++++++++++++++
.../pattern/RabbitMQPatternProcessorTest.java | 41 +++++
11 files changed, 698 insertions(+)
diff --cc connectors/rocketmq-connect-rabbitmq/README.md
index 0000000,708bee3..708bee3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/README.md
+++ b/connectors/rocketmq-connect-rabbitmq/README.md
diff --cc connectors/rocketmq-connect-rabbitmq/pom.xml
index 0000000,d5687c1..d5687c1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/pom.xml
+++ b/connectors/rocketmq-connect-rabbitmq/pom.xml
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
index 0000000,5f70361..5f70361
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
index 0000000,2b12c18..2b12c18
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
index 0000000,328632d..328632d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
index 0000000,ab2d1e4..ab2d1e4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
index 0000000,5056a11..5056a11
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
index 0000000,7228f68..7228f68
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
index 0000000,ea52a43..ea52a43
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
index 0000000,232ddc1..232ddc1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
diff --cc connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java
index 0000000,a23d233..a23d233
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java
+++ b/connectors/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java