Confluent Kafka Mongo Sink连接器连接异常求助

1. 优先解决MongoDB证书IP不匹配问题 #

证书验证失败是引发后续连接超时、集群状态异常的核心根源：

• 检查MongoDB副本集每个节点的证书SAN（Subject Alternative Name）字段，必须包含节点的实际IP地址和主机名。MongoDB 7.0副本集模式下，客户端会尝试连接所有副本节点，任一节点证书不匹配都会中断连接链。
• 调整Kafka Connect的Mongo Sink配置：如果用IP连接Mongo，确保mongodb.uri中的地址和证书SAN里的IP完全一致；如果用主机名，先确认Connect节点能正确解析该主机名，且证书包含此主机名。
• 在Connect节点上执行命令验证证书匹配性：openssl s_client -connect <mongo-host>:<port> -CAfile <ca-cert-path>，查看返回的证书SAN字段，确认包含当前连接的IP/主机名。

2. 修复MongoDB集群状态UNKNOWN与REPLICA_SET_GHOST问题 #

证书问题解决后，再处理集群识别异常：

• 确保Mongo Sink连接器使用完整的副本集URI格式：mongodb://user:pass@node1:port,node2:port,node3:port/dbname?replicaSet=rsName&ssl=true，不能只填单个节点地址。
• 在Mongo主节点执行rs.status()，确认所有副本节点状态为PRIMARY或SECONDARY，无UNKNOWN节点，且副本集名称和连接器配置的replicaSet参数完全一致。
• 增加连接器连接超时参数：在配置中添加mongodb.connection.timeout.ms=30000、mongodb.socket.timeout.ms=30000，避免SSL握手耗时过长导致超时。

3. 解决Confluent监控拦截器节点断开问题 #

监控拦截器的异常通常是连接器连接失败的连锁反应：

• 检查Connect集群配置文件connect-distributed.properties，确认consumer.interceptor.classes包含io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor，且Confluent Control Center的地址配置正确。
• 重启Mongo Sink连接器，让监控拦截器重新建立与连接器消费者的关联。
• 查看Connect节点的connect.log，过滤confluent.monitoring.interceptor相关日志，排查是否存在资源不足或权限问题（比如拦截器无法向Control Center上报指标）。

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