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/01 12:52:42 UTC
[rocketmq-connect] branch master updated (308a3da -> 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.
from 308a3da first commit
new 380a6f8 [ISSUE #333] Adjust runtime structure and add sample project (#331)
new e136df2 [ISSUE #344] Update the fastjson version of runtime to 1.2.58 (#347)
new 8d40202 Isolated loading task and connector
new 827377d Fix unit test null pointer problem
new 8d2dd69 Change the name of the parameter workerSourceTasks to workerTasks (#362)
new 6ac3207 Fix sink task stop bug (#360)
new 8fff7ea [ISSUE #357] Supplementary readme documentation (#358)
new cea64c6 [ISSUE 368]Polish rocketmq replicator implementation (#366)
new ba53128 Polish rocketmq connect pom file and config (#367)
new e1cef98 [ISSUE #363] File connector configures a separate log file (#364)
new bc8fbca [ISSUE #345]merge rmq client (#348)
new f724c6a [ISSUE #375]Refactoring cluster discovery module, removed the message exchange dependency (#387)
new 1cb02b9 Fix sink task stop bug
new c6291e2 Different tasks different rmqProducerGroup
new 5bf6a99 Fix multi-task producer/consumer to create the same group error bug
new 21c9b84 Fix load fat jar bug
new d5c6cd4 Rollback group modification
new ab13ba2 Roll back temporary modification code
new f6d072a Fix isolation load class error
new c502145 Merge pull request #390 from odbozhou/bugfix_loadFatJar1
new 1c8264d [ISSUE #393]Optimize runtime source task start
new fc63452 Merge pull request #402 from yiliuchen/pr1
new 7730ea4 Merge branch 'master' into isolation_load
new 1b1ea2c Restful add eliminate, stopAll interface. resolve #379
new f849fc1 chore(runtime/replicator): change rocketmq dependency from 4.4.0 to 4.5.2
new 82ab394 runtime support dynamic update connector. resolve #376
new d211b70 Merge pull request #425 from xujianhai666/feat-reloadconn
new 351d70a fix(rocketmq-connect-runtime): add "stopAll" at first
new ed87207 fix(rocketmq-connect-runtime): add "stopAll" at first
new 7eb19ce Merge pull request #436 from ClementIV/runtime
new 6e67583 feat(replicator):Add allocate ConnAndTask by consistent hash
new f585e0c [ISSUE #431] Fix loadclass failed from classpath
new 7953965 Merge pull request #449 from yiliuchen/fixclassload
new db0709f feat(connector): Support AllocateConnAndTaskStrategy configuration.
new c14cc9d Merge pull request #461 from xujianhai666/feat-taskStrategy
new d931300 [ISSUE #392] Runtime supports source or sink processing data does not depend on converter (#401)
new 86604ba Add friendly reminder for the lack of cluster store topic (#466)
new 811641d feat(replicator): Add commitRecord after producer send success (#452)
new d9bd144 Support receive nested json (#477)
new 31f07c1 [ISSUE #460] fix(console,runtime):fix spell error in userguide (#484)
new b31860f [ISSUE #478] TopicList is null exception and frequent requestTaskReconfiguration (#483)
new 9da2f94 docs(runtime): add load balance docs (#494)
new 1dfd619 [ISSUE #492] Optimize metadata synchronization and fix RocketMQConverter bug (#493)
new a3f2ba5 [ISSUE #541] Fix Checkstyle issue in rocketmq-connect (#542)
new a29517a 1.add rocketmq-tools dependency so rocketmq-connect-jdbc can run on it (#537)
new ec95788 [ISSUE #564] Fix typo
new 193e0bd fix(connect-runtime) remove unused local variable
new b72ac7b [ISSUE #556] Remove unused local variable (#557)
new 95cc570 [ISSUE #562] add triggerListener when removing connector configs (#585)
new 703882a [ISSUE #558] An ugly solution for fetch topic list error
new b3ebedf [ISSUE #540] Add task lifecycle management; fix stopAll bug (#598)
new 2d4874a [ISSUE #570] ASoC connect runtime optimization: CLI (#622)
new 9f112f5 bug(connect-runtime) stop polling from paused tasks (#613)
new 761da9a [Replicator] Restart of connector causes message duplication problem & Unit test bug fix (#694)
new d058610 [rocketmq-connect] Multi-producer instance. (#704)
new 2baa426 fix(connect-runtime)position repeat commit (#759)
new 5553e3f [rocketmq-connect] Adjust task check order (#703)
new 15944cd [rocketmq-connect] Solve the problem of message duplication caused by worker shutdown (#698)
new 23c59b3 [ISSUE #796] add task woker thread name (#795)
new 486d9bd [ISSUE #798] fields will not be built in SinkDataEntry (#797)
new 3263bf1 support divide by topic queue in allocate strategy (#805)
new 8e21d79 [ISSUE #801]Rocketmq connector sink for hudi (#800)
new 4d47cf0 [rocketmq-connect] fix checkstyle (#818)
new 5ed24c6 [ISSUE #822] Update .travis.yml (#823)
new dede656 [rocketmq-connect] support acl
new e0162cd [ISSUE #824] Add WorkerDirectTask (#825)
new 0b1b6da [ISSUE #821] Support auto create subGroup (#828)
new d224c55 fix typo (#855)
new cd237bf [rocketmq-connect] Synchronize the latest position (#701)
new a1e5f60 Merge branch 'rocketmq_connect1' of https://github.com/apache/rocketmq-externals
The 70 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:
LICENSE | 201 +++++++
README.md | 296 ++++++++++
pom.xml | 178 ++++++
rocketmq-connect-cli/README.md | 69 +++
rocketmq-connect-cli/connectAdmin | 18 +
rocketmq-connect-cli/pom.xml | 186 ++++++
.../rocketmq/connect/cli/ConnectAdminStartup.java | 194 +++++++
.../cli/command/CreateConnectorSubCommand.java | 92 +++
.../cli/command/GetAllocatedConnectors.java | 88 +++
.../cli/command/GetAllocatedInfoCommand.java | 63 +++
.../connect/cli/command/GetAllocatedTasks.java | 94 +++
.../cli/command/GetClusterInfoSubCommand.java | 63 +++
.../cli/command/GetConfigInfoSubCommand.java | 63 +++
.../command/QueryConnectorConfigSubCommand.java | 70 +++
.../command/QueryConnectorStatusSubCommand.java | 70 +++
.../cli/command/ReloadPluginsSubCommand.java | 63 +++
.../connect/cli/command/StopAllSubCommand.java | 63 +++
.../cli/command/StopConnectorSubCommand.java | 70 +++
.../rocketmq/connect/cli/command/SubCommand.java | 32 ++
.../connect/cli/commom/CLIConfigDefine.java | 25 +
.../apache/rocketmq/connect/cli/commom/Config.java | 44 ++
.../connect/cli/commom/ConnectKeyValue.java | 149 +++++
.../connect/cli/utils/FileAndPropertyUtil.java | 117 ++++
.../rocketmq/connect/cli/utils/RestSender.java | 57 ++
.../rocketmq/connect/cli/utils/ServerUtil.java | 80 +++
.../src/main/resources/connect.conf | 20 +
.../src/main/resources/package.xml | 40 ++
rocketmq-connect-runtime/pom.xml | 233 ++++++++
rocketmq-connect-runtime/run_worker.sh | 17 +
.../connect/runtime/ConnectController.java | 236 ++++++++
.../rocketmq/connect/runtime/ConnectStartup.java | 139 +++++
.../connect/runtime/common/ConnAndTaskConfigs.java | 54 ++
.../connect/runtime/common/ConnectKeyValue.java | 148 +++++
.../connect/runtime/common/LoggerName.java | 25 +
.../connect/runtime/config/ConnectConfig.java | 380 +++++++++++++
.../runtime/config/RuntimeConfigDefine.java | 99 ++++
.../connect/runtime/connectorwrapper/Worker.java | 628 +++++++++++++++++++++
.../runtime/connectorwrapper/WorkerConnector.java | 93 +++
.../runtime/connectorwrapper/WorkerDirectTask.java | 266 +++++++++
.../runtime/connectorwrapper/WorkerSinkTask.java | 529 +++++++++++++++++
.../runtime/connectorwrapper/WorkerSourceTask.java | 311 ++++++++++
.../runtime/connectorwrapper/WorkerState.java | 24 +
.../runtime/connectorwrapper/WorkerTask.java | 38 ++
.../runtime/connectorwrapper/WorkerTaskState.java | 30 +
.../runtime/converter/ByteBufferConverter.java | 36 ++
.../connect/runtime/converter/ByteConverter.java | 36 ++
.../runtime/converter/ByteMapConverter.java | 73 +++
.../converter/ConnAndTaskConfigConverter.java | 68 +++
.../connect/runtime/converter/JsonConverter.java | 76 +++
.../connect/runtime/converter/ListConverter.java | 63 +++
.../runtime/converter/RocketMQConverter.java | 34 ++
.../rocketmq/connect/runtime/rest/RestHandler.java | 246 ++++++++
.../runtime/service/ClusterManagementService.java | 70 +++
.../service/ClusterManagementServiceImpl.java | 157 ++++++
.../runtime/service/ConfigManagementService.java | 103 ++++
.../service/ConfigManagementServiceImpl.java | 354 ++++++++++++
.../runtime/service/DefaultConnectorContext.java | 62 ++
.../service/OffsetManagementServiceImpl.java | 248 ++++++++
.../runtime/service/PositionManagementService.java | 86 +++
.../service/PositionManagementServiceImpl.java | 248 ++++++++
.../connect/runtime/service/RebalanceImpl.java | 107 ++++
.../connect/runtime/service/RebalanceService.java | 97 ++++
.../runtime/service/TaskPositionCommitService.java | 74 +++
.../strategy/AllocateConnAndTaskStrategy.java | 41 ++
...llocateConnAndTaskStrategyByConsistentHash.java | 102 ++++
.../DefaultAllocateConnAndTaskStrategy.java | 86 +++
.../runtime/store/FileBaseKeyValueStore.java | 129 +++++
.../connect/runtime/store/KeyValueStore.java | 95 ++++
.../runtime/store/MemoryBasedKeyValueStore.java | 75 +++
.../runtime/store/PositionStorageReaderImpl.java | 54 ++
.../connect/runtime/utils/ConnectUtil.java | 163 ++++++
.../connect/runtime/utils/CountDownLatch2.java | 182 ++++++
.../connect/runtime/utils/FileAndPropertyUtil.java | 145 +++++
.../connect/runtime/utils/FilePathConfigUtil.java | 39 ++
.../rocketmq/connect/runtime/utils/Plugin.java | 179 ++++++
.../connect/runtime/utils/PluginClassLoader.java | 74 +++
.../connect/runtime/utils/PluginUtils.java | 245 ++++++++
.../connect/runtime/utils/PluginWrapper.java | 75 +++
.../rocketmq/connect/runtime/utils/ServerUtil.java | 79 +++
.../connect/runtime/utils/ServiceThread.java | 132 +++++
.../connect/runtime/utils/TransferUtils.java | 119 ++++
.../runtime/utils/datasync/BrokerBasedLog.java | 200 +++++++
.../runtime/utils/datasync/DataSynchronizer.java | 43 ++
.../utils/datasync/DataSynchronizerCallback.java | 34 ++
.../src/main/resources/connect.conf | 36 ++
.../src/main/resources/log4j.properties | 45 ++
.../src/main/resources/logback.xml | 107 ++++
.../src/main/resources/package.xml | 40 ++
.../src/main/resources/user.avsc | 9 +
.../runtime/common/ConnectKeyValueTest.java | 64 +++
.../connect/runtime/config/ConnectConfigTest.java | 32 ++
.../connectorwrapper/WorkerConnectorTest.java | 61 ++
.../runtime/connectorwrapper/WorkerTest.java | 170 ++++++
.../connectorwrapper/testimpl/TestConnector.java | 67 +++
.../connectorwrapper/testimpl/TestConverter.java | 33 ++
.../testimpl/TestPositionManageServiceImpl.java | 60 ++
.../testimpl/TestPositionStorageReader.java | 36 ++
.../connectorwrapper/testimpl/TestSourceTask.java | 69 +++
.../connectorwrapper/testimpl/TestTask.java | 47 ++
.../runtime/converter/ByteConverterTest.java | 35 ++
.../runtime/converter/ByteMapConverterTest.java | 44 ++
.../runtime/converter/JsonConverterTest.java | 43 ++
.../connect/runtime/rest/RestHandlerTest.java | 259 +++++++++
.../service/ConfigManagementServiceImplTest.java | 225 ++++++++
.../service/PositionManagementServiceImplTest.java | 266 +++++++++
...ateConnAndTaskStrategyByConsistentHashTest.java | 116 ++++
.../DefaultAllocateConnAndTaskStrategyTest.java | 114 ++++
.../runtime/store/FileBaseKeyValueStoreTest.java | 42 ++
.../connect/runtime/utils/CountDownLatch2Test.java | 55 ++
.../runtime/utils/FileAndPropertyUtilTest.java | 105 ++++
.../rocketmq/connect/runtime/utils/TestUtils.java | 39 ++
.../connect/runtime/utils/TransferUtilsTest.java | 128 +++++
.../runtime/utils/datasync/BrokerBasedLogTest.java | 114 ++++
rocketmq-connect-sample/pom.xml | 77 +++
.../apache/rocketmq/connect/file/FileConfig.java | 80 +++
.../rocketmq/connect/file/FileConstants.java | 32 ++
.../rocketmq/connect/file/FileSinkConnector.java | 65 +++
.../apache/rocketmq/connect/file/FileSinkTask.java | 105 ++++
.../rocketmq/connect/file/FileSourceConnector.java | 66 +++
.../rocketmq/connect/file/FileSourceTask.java | 267 +++++++++
.../apache/rocketmq/connect/file/FileUtils.java | 62 ++
.../apache/rocketmq/connect/file/LoggerName.java | 25 +
style/copyright/Apache.xml | 24 +
style/copyright/profiles_settings.xml | 64 +++
style/rmq_checkstyle.xml | 141 +++++
style/rmq_codeStyle.xml | 143 +++++
126 files changed, 13896 insertions(+)
create mode 100644 LICENSE
create mode 100644 pom.xml
create mode 100644 rocketmq-connect-cli/README.md
create mode 100644 rocketmq-connect-cli/connectAdmin
create mode 100644 rocketmq-connect-cli/pom.xml
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/ConnectAdminStartup.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/CreateConnectorSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetAllocatedConnectors.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetAllocatedInfoCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetAllocatedTasks.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetClusterInfoSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/GetConfigInfoSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/QueryConnectorConfigSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/QueryConnectorStatusSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/ReloadPluginsSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/StopAllSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/StopConnectorSubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command/SubCommand.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/CLIConfigDefine.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/Config.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom/ConnectKeyValue.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/FileAndPropertyUtil.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/RestSender.java
create mode 100644 rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils/ServerUtil.java
create mode 100644 rocketmq-connect-cli/src/main/resources/connect.conf
create mode 100644 rocketmq-connect-cli/src/main/resources/package.xml
create mode 100644 rocketmq-connect-runtime/pom.xml
create mode 100755 rocketmq-connect-runtime/run_worker.sh
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/ConnectController.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/ConnectStartup.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnAndTaskConfigs.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/LoggerName.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/ConnectConfig.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/RuntimeConfigDefine.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerState.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTaskState.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/ByteBufferConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/ByteConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/ByteMapConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/ConnAndTaskConfigConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/JsonConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/ListConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/RocketMQConverter.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementService.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImpl.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementServiceImpl.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/DefaultConnectorContext.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/OffsetManagementServiceImpl.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementServiceImpl.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceService.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/TaskPositionCommitService.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategy.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHash.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategy.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStore.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/KeyValueStore.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/MemoryBasedKeyValueStore.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FilePathConfigUtil.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Plugin.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/PluginClassLoader.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/PluginUtils.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/PluginWrapper.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServerUtil.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServiceThread.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/TransferUtils.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizer.java
create mode 100644 rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizerCallback.java
create mode 100644 rocketmq-connect-runtime/src/main/resources/connect.conf
create mode 100644 rocketmq-connect-runtime/src/main/resources/log4j.properties
create mode 100644 rocketmq-connect-runtime/src/main/resources/logback.xml
create mode 100644 rocketmq-connect-runtime/src/main/resources/package.xml
create mode 100644 rocketmq-connect-runtime/src/main/resources/user.avsc
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValueTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/config/ConnectConfigTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnectorTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestConnector.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestConverter.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionManageServiceImpl.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestPositionStorageReader.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestSourceTask.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/connectorwrapper/testimpl/TestTask.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/ByteConverterTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/ByteMapConverterTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/converter/JsonConverterTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/rest/RestHandlerTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementServiceImplTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/PositionManagementServiceImplTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHashTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategyTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStoreTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/CountDownLatch2Test.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtilTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/TestUtils.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/TransferUtilsTest.java
create mode 100644 rocketmq-connect-runtime/src/test/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLogTest.java
create mode 100644 rocketmq-connect-sample/pom.xml
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConfig.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileConstants.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSinkConnector.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSinkTask.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceConnector.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileUtils.java
create mode 100644 rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/LoggerName.java
create mode 100644 style/copyright/Apache.xml
create mode 100644 style/copyright/profiles_settings.xml
create mode 100644 style/rmq_checkstyle.xml
create mode 100644 style/rmq_codeStyle.xml