Hi,
ResumeToken[1] can be considered globally unique[2].
Best,
Jiabao
[1] https://www.mongodb.com/docs/manual/changeStreams/#resume-tokens
[2]
https://img.alicdn.com/imgextra/i4/O1CN010e81SP1vkgoyL0nhd_!!66211-0-tps-2468-1360.jpg
On 2024/01/22 09:36:42 "casel.chen" wrote:
>
>
>
>
V1版本依赖于DebeziumSourceFunction，后者依赖于DebeziumEngine产生changelog
V2版本虽然依赖了 flink-connector-debezium 但没有用到debezium内部类
另外有一个问题：mongodb change stream断点续传用的resumeToken是像mysql binlog offset一样全局唯一么？
如果数据源是像kafka一样每个分片有binlog offset的话，
是不是要在对应xxxOffset类中要定义一个Map类型的offsetField
