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:06:37 UTC
[rocketmq-connect] branch master updated (258e37e -> a1e5f60)
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.
omit 258e37e Add 'connector/rocketmq-replicator/' from commit '55631bb1fe4d3864c2d45dc7fee9e49764d7b3ac'
omit ce39378 Add 'connector/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
omit 5feab9c Add 'connector/rocketmq-connect-rabbitmq/' from commit 'a7ab1c46a9938df2984c3ad730609c1a7797cc9b'
omit 232c585 Add 'connector/rocketmq-connect-mongo/' from commit 'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
omit 00d60fb Add 'connector/rocketmq-connect-kafka/' from commit '59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
omit b3cbb0b Add 'connector/rocketmq-connect-jms/' from commit '37a4db762dfac7496e2e0e40cf7cf25c4bd0f01d'
omit 24c083e Add 'connector/rocketmq-connect-jdbc/' from commit '6708ada617d9f6cfef5ca42a3c2f97af44603a89'
omit 386adcc Add 'connector/rocketmq-connect-hudi/' from commit '5da4b78705108ac6d260283cd38f9be08d2590b9'
omit fafa276 Add 'connector/rocketmq-connect-cassandra/' from commit 'e2cc843ef4926a98797ca76880579941d5363fc6'
omit 0669f46 Add 'connector/rocketmq-connect-activemq/' from commit 'e8aedf31c7eb4b26a2d9df7c766427fdfd845e9f'
omit 4fdd8b2 Fix exception parsing redis command "set a 1010 px 1000" (#862)
omit 5da4b78 fix hudi connect config
omit 59ac9fd [rocketmq-connect-kafka]: Completion method KafkaSourceTask#pause(), KafkaSourceTask#resume(). (#854)
omit 55631bb [rocketmq-replicator] Support subGroup whitelist (#843)
omit d1845c5 [rocketmq-replicator] Fix topic build route logic (#834)
omit 691ff01 [rocketmq-replicator] Bug fix: Missing subscription group when syncing offset (#837)
omit 1ca3a07 [rocketmq-replicator] Support ACL (#832)
omit a0b10aa [ISSUE #699] [Replicator] The source task starts to check the position (#700)
omit 44bb9bd [ISSUE #801]Rocketmq connector sink for hudi (#800)
omit 6708ada Merge branch 'master' of github.com:apache/rocketmq-externals
omit 8e66fd6 [Replicator] Fix message duplication problem (#692)
omit 5f40a88 Update README.md (#553)
omit 8a07d71 Update rocketmq-connect-redis pom.xml (#592)
omit b425260 [ISSUE #570] ASoC connect runtime optimization: CLI (#622)
omit e2cc843 [ISSUE #570] ASoC runtime optimization: Cassandra connectors (#587)
omit 1a49e60 [ISSUE #558] An ugly solution for fetch topic list error
omit 9849db6 [ISSUE #554] Update druid version and set ConnectionErrorRetryAttempts
omit 37a4db7 fix(connect-jms) should put .iml file in gitignore
omit 4e3ccda fix(connect-runtime) remove unused local variable
omit ed629ae update rocketmq-connect-redis dependency (#583)
omit a1f2ff2 [ISSUE #550] Removed unnecessary value of REQUEST_CONFIG in Config.java (#551)
omit 0b56e47 [ISSUE #545]bug fix (#546)
omit 5420e44 1.add required fields in RockeMQ jdbc connector 2. add docs (#539)
omit e325d72 1.add rocketmq-tools dependency so rocketmq-connect-jdbc can run on it (#537)
omit b9802ae fix(jdbc-connect) removed unused class (#544)
omit 7ebfedf fix(jdbc-connect) removed unused class
omit 18f2061 bump up the connect version to 0.1.1
omit b307466 bump up the connect version to 0.1.1
omit 2e8ea2e Update README.md
omit 7c81b41 Update connector dependency to the latest version
omit 1290dde Support redis 6 (#510)
omit 252e26a [ISSUE #495] jdbc-sink-connector support divide task by queue (#496)
omit 341d6f3 [ISSUE #489] JDBC Connector support divide task by topic strategy (#490)
omit b0ca555 docs(replicator): add introduction of replicator (#507)
omit d2e168e Supplemental replicator documentation (#506)
omit 759e422 [ISSUE #498] update rocketmq-jdbc-connector README.md (#499)
omit ae2751e [ISSUE 503] Metadata synchronization optimization (#504)
omit 070dd98 [ISSUE #492] Optimize metadata synchronization and fix RocketMQConverter bug (#493)
omit f55d213 [ISSUE #478] TopicList is null exception and frequent requestTaskReconfiguration (#483)
omit d06e10c [ISSUE #487] Jdbc source connector support syncing data with white ta… (#488)
omit 42cbfb3 [ISSUE #485] Support repeat consumption (#486)
omit 7201d00 [ISSUE #468] Replicator is packaged as fatjar (#472)
omit 5ed354b The topic name in the TaskTopicInfo constructor should be topic (#473)
omit 6182624 When replicator stop, stop MQAdminExt and Listener (#474)
omit ff09b42 feat(replicator): Add commitRecord after producer send success (#452)
omit 2d00797 feat(replicator): support DivideTaskByConsistentHash (#443)
omit 182fd46 [ISSUE #441] Add Jdbc Sink Connector (#442)
omit b3377a6 [ISSUES #434] Replicator support RocketMQConverter (#463)
omit d7b0ce8 feat(replicator): Support subcriptionConfig sync
omit a321762 feat(replicator):add consumer offset sync
omit dfb32fd chore(runtime/replicator): change rocketmq dependency from 4.4.0 to 4.5.2
omit e74c022 [ISSUE #420]remove openmessage-runtime dependency
omit caea266 Merge pull request #424 from xujianhai666/feat-queuelistener
omit 6809200 Merge pull request #422 from xujianhai666/fix-emptyTopic
omit ebb44c1 Increase topic change awareness monitoring. resolve #398
omit d4e677d fix sourceTaskTopicList is null. resolve #386
omit 90541a2 add DivideTaskByQueue. resolve #397
omit ad38ec7 extend messageQueue for TaskTopicInfo
omit 81376b9 Topic rename. resolve #399
omit b4f8cd9 Automatically create target topic. resolve #396
omit db7644a Update JdbcSourceTask.java
omit 5457c06 Update JdbcSourceTask.java
omit 717d4a2 Update Schema.java
omit d80142a Support wildcard subscription topic. resolve #395
omit 14da1d8 Add Redis connector. (#403)
omit db51f7f clean code
omit 2cdb27a fix some bug and add readme
omit 8a266e8 update readme
omit 0521831 Delete JdbcSourceTaskTest.java
omit e72688b Update Querier.java
omit 4849ff5 Update TimestampIncrementingQuerier.java
omit 1376d82 Develop TimestampIncrementingQuerier Mode
omit f193fcd reformat code and add more test case
omit ef2a365 Update README.md
omit 98da0fb fix test verifyConfig
omit f95bf22 support multiple mongo replicaset
omit 40b9fc8 [ISSUE 368]Polish rocketmq replicator implementation (#366)
omit c1a51cc 【ISSUE #278】Define and Implement the RmqConnector and RmqSourceTask. (#381)
omit cd6410d Update JdbcSourceConnectorTest.java
omit 25e699e return taskConfig with source-record-converter (#373)
omit d0569b7 Update Querier.java
omit 488223c develop the jdbcsource connector
omit 6777f23 fix bug
omit 70caed3 fix some bug
omit 32d3165 fix some bug
omit b1acd43 delete lib
omit c7a2c41 [ISSUE #351] rmq client setInstanceName on sourceTask (#355)
omit e84812e 修改stop
omit 6ca400a add junit test and modify some code
omit f629088 add junit test and modify some code
omit a1d1200 Delete ReplicatorTest.java
omit 8ecde45 Add JdbcSourceTask and Schema
omit 9ea583f Add SourceJdbcTask and Schema
omit e915f67 Add JdbcSourceTask and Schema
omit 5a83890 Add JdbcSourceTask
omit 598de5d [ISSUE #341] Add wakeup before kafka consumer close to wakeup consumer poll (#342)
omit 6ddd7e4 Define and Implement the RmqConnector and RmqSourceTask. (#343)
omit 9aa0640 Update README.md for rocketmq-connect-kafka (#338)
omit 2cc48d9 Add Config File
omit a7ab1c4 [ISSUE #312] Implement rocketmq connect RabbitMQ (#313)
omit 6801219 [ISSUE #312] Implement rocketmq connect RabbitMQ (#313)
omit 3c5f659 Add Jdbc Source Task (To be continued)
omit 8862e3e Init rocketmq-connect-redis
omit 675099d Update JdbcSourceConnector.java
omit 5db4b46 Update Config.java
omit 9716b10 Update pom.xml
omit 13b6ae3 Add Jdbc Source Connector and Do Unit Test
omit a9fb3af Init rocketmq-connect-jdbc
omit 208e4ed init commit (#309)
omit bbb1202 rocketmq-connect-kafka
omit 78cc902 [ISSUE #302] Implement rocketmq connect jms (#303)
omit 4e42a37 Initial rocketmq-connect-rabbitmq
omit 8b8c95f Initial rocketmq-connect-jms project
omit e8aedf3 Change README.md (#301)
omit 3da8a3f format pom.xml
omit db391c5 change exception
omit 23a5b24 add licenses
omit 508eea1 add unit test
omit d0ff0aa Init rocketmq-kafka connect project
omit d50ffb8 message type
omit 6663768 change
omit da0b21f change
omit 30b02f4 change package name
omit c7c0c04 init complete
omit 952aa8f (1)Rename rocketmq-connector to replicator (2) Initialize RocketMQ activemq connect and runtime
omit f4221ce (1)Rename rocketmq-connector to replicator (2) Initialize RocketMQ activemq connect and runtime
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/master (a1e5f60)
\
O -- O -- O (258e37e)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
connector/rocketmq-connect-activemq/README-CN.md | 16 -
connector/rocketmq-connect-activemq/README.md | 16 -
connector/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 ---
connector/rocketmq-connect-cassandra/README.md | 97 --
connector/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 -
connector/rocketmq-connect-hudi/README.md | 77 --
connector/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 ---
connector/rocketmq-connect-jdbc/README.md | 85 --
connector/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 --
connector/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 --
connector/rocketmq-connect-kafka/README.md | 30 -
connector/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 -
connector/rocketmq-connect-mongo/README.md | 43 -
connector/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 --
connector/rocketmq-connect-rabbitmq/README.md | 17 -
connector/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 -
connector/rocketmq-connect-redis/README-CN.md | 19 -
connector/rocketmq-connect-redis/README.md | 19 -
connector/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 ---
connector/rocketmq-replicator/.gitignore | 13 -
connector/rocketmq-replicator/README.md | 69 --
connector/rocketmq-replicator/package.xml | 41 -
connector/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 --
321 files changed, 28224 deletions(-)
delete mode 100644 connector/rocketmq-connect-activemq/README-CN.md
delete mode 100644 connector/rocketmq-connect-activemq/README.md
delete mode 100644 connector/rocketmq-connect-activemq/pom.xml
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Config.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/ErrorCode.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/Replicator.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java
delete mode 100644 connector/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/pattern/PatternProcessor.java
delete mode 100644 connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/ReplicatorTest.java
delete mode 100644 connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqConnectorTest.java
delete mode 100644 connector/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
delete mode 100644 connector/rocketmq-connect-cassandra/README.md
delete mode 100644 connector/rocketmq-connect-cassandra/pom.xml
delete mode 100644 connector/rocketmq-connect-cassandra/scripts/gen_data.py
delete mode 100644 connector/rocketmq-connect-cassandra/scripts/requirements.txt
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/CloneUtils.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DBUtils.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/DataType.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/Utils.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SinkDbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskDivideConfig.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/TaskTopicInfo.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Table.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BigIntColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/ColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DateTimeColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/EnumColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/IntColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/SetColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/StringColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/TimeColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/YearColumnParser.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideStrategyEnum.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java
delete mode 100644 connector/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/TaskDivideStrategy.java
delete mode 100644 connector/rocketmq-connect-hudi/README.md
delete mode 100644 connector/rocketmq-connect-hudi/pom.xml
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/CloneUtils.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/ConfigUtil.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/HudiConnectConfig.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/SinkConnectConfig.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/config/Utils.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkConnector.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/connector/HudiSinkTask.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/ITaskDivideStrategy.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideByQueueStrategy.java
delete mode 100644 connector/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/strategy/TaskDivideStrategyFactory.java
delete mode 100644 connector/rocketmq-connect-hudi/style/rmq_checkstyle.xml
delete mode 100644 connector/rocketmq-connect-jdbc/README.md
delete mode 100644 connector/rocketmq-connect-jdbc/pom.xml
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java
delete mode 100644 connector/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java
delete mode 100644 connector/rocketmq-connect-jms/pom.xml
delete mode 100644 connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java
delete mode 100644 connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/ErrorCode.java
delete mode 100644 connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Replicator.java
delete mode 100644 connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnector.java
delete mode 100644 connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java
delete mode 100644 connector/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java
delete mode 100644 connector/rocketmq-connect-jms/src/test/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceConnectorTest.java
delete mode 100644 connector/rocketmq-connect-kafka/README.md
delete mode 100644 connector/rocketmq-connect-kafka/pom.xml
delete mode 100644 connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigDefine.java
delete mode 100644 connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/config/ConfigUtil.java
delete mode 100644 connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java
delete mode 100644 connector/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTask.java
delete mode 100644 connector/rocketmq-connect-kafka/src/main/resources/connect-kafka-source.properties
delete mode 100644 connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnectorTest.java
delete mode 100644 connector/rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
delete mode 100644 connector/rocketmq-connect-mongo/README.md
delete mode 100644 connector/rocketmq-connect-mongo/pom.xml
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
delete mode 100644 connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
delete mode 100644 connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/README.md
delete mode 100644 connector/rocketmq-connect-rabbitmq/pom.xml
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/jms/RabbitmqConfigTest.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnectorTest.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTaskTest.java
delete mode 100644 connector/rocketmq-connect-rabbitmq/src/test/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessorTest.java
delete mode 100644 connector/rocketmq-connect-redis/README-CN.md
delete mode 100644 connector/rocketmq-connect-redis/README.md
delete mode 100644 connector/rocketmq-connect-redis/pom.xml
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
delete mode 100644 connector/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
delete mode 100644 connector/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
delete mode 100644 connector/rocketmq-connect-redis/style/copyright/Apache.xml
delete mode 100644 connector/rocketmq-connect-redis/style/copyright/profiles_settings.xml
delete mode 100644 connector/rocketmq-connect-redis/style/rmq_checkstyle.xml
delete mode 100644 connector/rocketmq-connect-redis/style/rmq_codeStyle.xml
delete mode 100644 connector/rocketmq-replicator/.gitignore
delete mode 100644 connector/rocketmq-replicator/README.md
delete mode 100644 connector/rocketmq-replicator/package.xml
delete mode 100644 connector/rocketmq-replicator/pom.xml
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqConstants.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/ConstDefine.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigDefine.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ConfigUtil.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/DataType.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfig.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskConfigEnum.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskDivideConfig.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/TaskTopicInfo.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSync.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/offset/OffsetSyncStore.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/schema/FieldName.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideStrategyEnum.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByConsistentHash.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByQueue.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/DivideTaskByTopic.java
delete mode 100644 connector/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy/TaskDivideStrategy.java
delete mode 100644 connector/rocketmq-replicator/src/test/java/org/apache/rocketmq/replicator/RmqSourceReplicatorTest.java