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 03:20:50 UTC
[rocketmq-connect] 42/43: Merge branch 'master' of github.com:apache/rocketmq-externals
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 <xx...@qq.com>
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(-)