This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 6708ada617d9f6cfef5ca42a3c2f97af44603a89 Merge: 7ebfedf 5f40a88 Author: xxxxx <[email protected]> AuthorDate: Fri Jun 4 12:13:13 2021 +0800 Merge branch 'master' of github.com:apache/rocketmq-externals * 'master' of github.com:apache/rocketmq-externals: (69 commits) [#715] Support the RocketMQ TableSource based on the new Source interface (#716) #720 fix rocketmq console fail to update nameserver address (#721) [ISSUE #711] Consumers can skip the accumulation of messages. (#712) [#705] Support the implementation of new Source interface (#706) fix(ssl): SelfSignedCertificate work well with JDK15 fix(jdk15): resolve aspecj exception [Replicator] Restart of connector causes message duplication problem & Unit test bug fix (#694) [Replicator] Fix message duplication problem (#692) Support query message by page (#688) [ISSUE #682] Fix wrong message trace detail (#683) Support DLQ topic resend message (#653) Fix too much warn log because non-exist retry topic (#681) Update README.md (#553) Update producer.html (#675) Fix dashboard notification when set rocketmq.config.enableDashBoardCollect=false (#679) [rocketmq-connector-flink] rebalance cause offset rollback to long time ago (#672) [ISSUE #666]Upgrade RocketMQ version (#667) Update .travis.yml Update .travis.yml Optimize dependencies and support JDK 11+ ... README.md | 81 ++++++++++++++-------- pom.xml | 3 +- .../rocketmq/connect/jdbc/common/CloneUtils.java | 28 ++++++++ .../rocketmq/connect/jdbc/common/ConstDefine.java | 2 +- .../rocketmq/connect/jdbc/common/DBUtils.java | 31 +++++---- .../rocketmq/connect/jdbc/config/Config.java | 13 ++-- .../connect/jdbc/config/SinkDbConnectorConfig.java | 11 +-- .../jdbc/config/SourceDbConnectorConfig.java | 4 +- .../connect/jdbc/connector/JdbcSinkConnector.java | 63 +++++++++-------- .../jdbc/connector/JdbcSourceConnector.java | 2 +- .../connect/jdbc/connector/JdbcSourceTask.java | 9 ++- .../apache/rocketmq/connect/jdbc/sink/Updater.java | 22 +++--- .../rocketmq/connect/jdbc/source/Querier.java | 7 +- .../jdbc/source/TimestampIncrementingQuerier.java | 6 +- .../connect/jdbc/strategy/DivideTaskByQueue.java | 3 +- .../connect/jdbc/strategy/DivideTaskByTopic.java | 25 ++++--- 16 files changed, 195 insertions(+), 115 deletions(-)
