使用Flink MongoDB CDC源连接器遭遇MongoTimeoutException求助

尝试将Mongo CDC连接器作为Flink作业的DataStream源，参照官方文档示例代码编写：

• 配置了副本集的三个节点地址、用户名密码、目标数据库及集合
• 使用JsonDebeziumDeserializationSchema进行反序列化
• 因mongodb+srv URI报错，改用普通节点地址

本地Flink集群运行作业后，作业在Flink UI中反复切换RUNNING与RESTARTING状态，报错com.mongodb.MongoTimeoutException，提示连接超时并伴随MongoSocketReadException。但：

• 通过Mongo Compass可正常连接该副本集
• 使用非CDC的Mongo源/汇连接器时（可正常使用mongodb+srv URI）无任何问题

当前使用Flink版本为1.20.0，依赖配置如下：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.20.0</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java</artifactId>
    <version>1.20.0</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-mongodb</artifactId>
    <version>1.20.0-1.19</version>
</dependency>

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-mongodb-cdc</artifactId>
    <version>3.2.1</version>
</dependency>

1. 依赖版本兼容性问题 #

Flink 1.20.0与flink-connector-mongodb 1.2.0-1.19存在版本不匹配，该连接器版本对应Flink 1.19，而Mongo CDC连接器3.2.1适配Flink 1.18-1.20，配套的基础Mongo连接器需要使用对应Flink 1.20的版本。
解决：更新flink-connector-mongodb依赖版本为适配Flink 1.20的版本，例如：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-mongodb</artifactId>
    <version>1.3.0-1.20</version>
</dependency>

2. Mongo CDC连接器副本集配置缺失 #

仅配置节点地址可能不足以让CDC连接器正确识别副本集，需要明确指定副本集名称，并调大连接超时参数以适配副本集的选举与连接逻辑。
解决：在连接配置中补充副本集名称，同时增加超时参数：

MongoSource<String> source = MongoSource.<String>builder()
    .uri("mongodb://user:pass@node1:27017,node2:27017,node3:27017/your-db?replicaSet=rs0")
    .databaseList("your-db")
    .collectionList("your-collection")
    .deserializer(new JsonDebeziumDeserializationSchema())
    .connectionTimeout(30000) // 30秒连接超时
    .socketTimeout(60000) // 60秒读取超时
    .build();

3. 底层Mongo驱动版本冲突 #

非CDC连接器与CDC连接器依赖的Mongo驱动版本可能不一致，导致连接逻辑出现冲突。Mongo CDC连接器基于Debezium实现，其底层驱动版本可能与flink-connector-mongodb的驱动版本不兼容。
解决：

• 检查Maven依赖树，排除冲突的Mongo驱动版本
• 显式指定统一的Mongo驱动版本，例如：

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongodb-driver-sync</artifactId>
    <version>4.11.1</version> <!-- 适配Flink CDC 3.2.1的稳定版本 -->
</dependency>

4. 本地网络或进程权限限制 #

虽然Mongo Compass能连接，但Flink作业运行的JVM进程可能受防火墙、网络代理限制，导致无法持续维持与Mongo节点的长连接。
解决：

• 检查Flink集群所在机器的防火墙规则，确保允许与所有Mongo副本集节点的27017端口通信
• 关闭本地代理（若开启），避免代理中断连接

内容的提问来源于stack exchange，提问作者zaro