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 b30952eb [ISSUE #456] replicator support checkpoint
add dcf4f51b [ISSUE #461] Update rocketmq verison to 4.9.5 in replicator
connector and polish the code (#462)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-replicator/pom.xml | 2 +-
.../replicator/ReplicatorCheckpointConnector.java | 4 +--
.../replicator/ReplicatorCheckpointTask.java | 5 ++-
.../replicator/ReplicatorHeartbeatConnector.java | 3 --
.../replicator/ReplicatorHeartbeatTask.java | 22 ++++++-------
.../rocketmq/replicator/ReplicatorSourceTask.java | 37 ++++++++++------------
.../rocketmq/replicator/RmqSourceReplicator.java | 2 +-
7 files changed, 32 insertions(+), 43 deletions(-)
