Flink CDC里如果想断点续传mongodb change stream的话，我应该传什么？

问题一：Flink CDC中，如果要断点续传MongoDB的Change Stream，应该传递全局唯一的resumeToken。Resume Token是用于标识MongoDB Change Stream中的特定位置的标记，它不是分片特定的。因此，在Flink CDC中，您只需要传递一个全局唯一的resumeToken即可。

问题二：如果数据源CDC binlog可以按分片独立消费的话，您可以将各分片的offset存储在SourceRecord的Map sourceOffset中。对于MongoDB，您可以使用Map来存储每个分片的offset。其中，key为分片ID，value为该分片对应的offset。

关于更新offsetMap的问题，您可以在每次消费获取到CDC record时，根据shardId和pos更新offsetMap。具体来说，您可以遍历record中的shards和pos数组，然后根据shardId找到对应的offset，并将其更新为新的pos值。这样，您就可以保持offsetMap的最新状态。

以下是一个示例代码片段，展示了如何更新offsetMap：

// 假设您已经获取到了包含shards和pos的CDC record对象
Map<String, String> offsetMap = new HashMap<>(); // 初始化offsetMap

for (int i = 0; i < record.getShards().size(); i++) {
    String shardId = record.getShards().get(i);
    String pos = record.getPos().get(i);
    offsetMap.put(shardId, pos); // 更新offsetMap
}

请注意，上述代码仅为示例，您需要根据实际情况进行适当的修改和调整。另外，如果您担心性能问题，可以考虑使用更高效的数据结构或缓存机制来管理offsetMap，以提高更新效率。

resumeToken的结构是这样的，可以认为全局唯一的。此回答来自钉群Flink CDC 社区。