[rocketmq-connect] branch master updated (43ed2bf -> 229c673)

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git.


    from 43ed2bf  [ISSUE #37] add licence #36
     new 5fba13f  adapt latest connect api
     new 45f1270  fix record position converter data test case error & connector.init(configs);
     new 3ffdc18  fix load connector api repeat
     new 56d2385  reblance add try cache
     new 5f824db  Merge branch 'master' into adapt_new_connect_api
     new 229c673  Merge pull request #7 from odbozhou/adapt_new_connect_api

The 222 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:
 pom.xml                                            |   2 +-
 .../runtime/config/RuntimeConfigDefine.java        |  25 +-
 .../connect/runtime/connectorwrapper/Worker.java   |   8 +-
 .../runtime/connectorwrapper/WorkerConnector.java  |  21 +-
 .../runtime/connectorwrapper/WorkerDirectTask.java | 101 +++---
 .../runtime/connectorwrapper/WorkerSinkTask.java   | 341 ++++++++++++---------
 .../runtime/connectorwrapper/WorkerSourceTask.java | 232 ++++++++------
 ...onConverter.java => RecordOffsetConverter.java} |  33 +-
 ...onverter.java => RecordPartitionConverter.java} |  33 +-
 ...verter.java => RecordPositionMapConverter.java} |  26 +-
 .../service/ClusterManagementServiceImpl.java      |   4 +-
 .../runtime/service/ConfigManagementService.java   |   4 +-
 .../service/ConfigManagementServiceImpl.java       |  18 +-
 .../runtime/service/DefaultConnectorContext.java   |  11 +-
 .../service/OffsetManagementServiceImpl.java       |  50 +--
 .../runtime/service/PositionManagementService.java |  29 +-
 .../service/PositionManagementServiceImpl.java     |  50 +--
 .../connect/runtime/service/RebalanceService.java  |   9 +-
 .../runtime/store/PositionStorageReaderImpl.java   |  32 +-
 .../connect/runtime/utils/ConnectUtil.java         |  48 +++
 .../rocketmq/connect/runtime/utils/Plugin.java     |   4 +-
 .../connect/runtime/utils/PluginUtils.java         |   1 +
 .../connect/runtime/utils/PluginWrapper.java       |   4 +-
 .../connectorwrapper/WorkerConnectorTest.java      |   2 +-
 .../runtime/connectorwrapper/WorkerTest.java       |   7 +-
 .../connectorwrapper/testimpl/TestConnector.java   |  41 +--
 .../testimpl/TestPositionManageServiceImpl.java    |  22 +-
 .../testimpl/TestPositionStorageReader.java        |  13 +-
 .../connectorwrapper/testimpl/TestSourceTask.java  |  63 ++--
 .../connectorwrapper/testimpl/TestTask.java        |  27 +-
 .../connect/runtime/rest/RestHandlerTest.java      |   4 +-
 .../service/PositionManagementServiceImplTest.java |  62 ++--
 .../rocketmq/connect/file/FileSinkConnector.java   |  18 +-
 .../apache/rocketmq/connect/file/FileSinkTask.java |  49 ++-
 .../rocketmq/connect/file/FileSourceConnector.java |  26 +-
 .../rocketmq/connect/file/FileSourceTask.java      |  98 +++---
 36 files changed, 845 insertions(+), 673 deletions(-)
 copy rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/{JsonConverter.java => RecordOffsetConverter.java} (71%)
 copy rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/{JsonConverter.java => RecordPartitionConverter.java} (71%)
 copy rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/{ByteMapConverter.java => RecordPositionMapConverter.java} (65%)