是的,Flink CDC支持MongoDB的CDC(Change Data Capture)连接器。MongoDB的变更流(Change Streams)是MongoDB 3.6版本提供的新特性,它可以提供简单的变更数据捕获接口,屏蔽了直接遍历Oplog的复杂度,并提供完整的故障恢复能力。
如果你在使用Flink CDC的MongoDB连接器时,发现无法捕捉到CDC消息,可能是因为变更流没有正确启用。你需要在MongoDB中为需要捕获变更数据的集合启用变更流,这可以通过执行相应的聚合操作来实现。
此外,你可能还需要确保你在MongoDB中有足够的权限来读取变更数据。你需要为你的Flink任务配置适当的用户名和密码,并确保这个用户有权限读取所需的变更数据。
如果以上步骤都正确执行了,但问题仍然存在,你可能需要查看MongoDB的日志,看看是否有任何与变更流相关的错误信息。同时,你也可以检查Flink的任务日志,看看是否有任何与CDC连接器相关的错误信息。