search

alibaba / MongoShake

MongoShake is a universal data replication platform based on MongoDB's oplog. Redundant replication and active-active replication are two most important functions. 基于mongodb oplog的集群复制工具，可以满足迁移和同步的需求，进一步实现灾备和多活功能。
GNU General Public License v3.0
1.72k stars 441 forks source link

v2.4.15拉取源端分片集到kafka无法获取change_stream,同时checkpoint不更新 #475

Closed wuhaopengpm closed 3 years ago

wuhaopengpm commented 3 years ago

tunnle=kafka mongo_url=分片集 incr_sync.mongo_fetch_method = change_stream

该模式下，无法获取change_stream(但是tunnle=direct是可以的)

相关信息: [2020/11/03 19:17:59 CST] [INFO] [name=mongos, stage=incr, get=0, filter=0, worker_consume=0, worker_apply=0, worker_failed_times=0, success=0, tps=0, ckpt_times=0, retransimit_times=0, tunnel_traffic=0.00B, lsn_ckpt={0[0, 0], 1970-01-01 08:00:00}, lsn_ack={0[0, 0], 1970-01-01 08:00:00}]]

vinllen commented 3 years ago

问题出在识别的时候抓不到初始checkpoint地址，然后从mongod上进行拉取了，2.6.16版本将会修复。

wuhaopengpm commented 3 years ago

好的，有预计的发版时间吗

vinllen commented 3 years ago

已发布