报错详情

com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: org.apache.flink.mongodb.shaded.com.mongodb.MongoCursorNotFoundException: Query failed with error code -5 and error message ‘Cursor 439591843189637214 not found on server 10.0.87.139:27017’ on server 10.0.87.139:27017

解决

java服务中配置了mongodb的连接地址是10.0.87.139:27017，这个地址是mongos的svc地址：

mongos有两个pod：

报错是MongoDB游标丢失问题。主要原因是mongos负载均衡导致的游标路由问题。

当查询创建游标时连接到mongos-A，但后续的getMore操作可能被Service负载均衡到mongos-B，mongos-B上找不到在mongos-A创建的游标，导致报错。

解决方式是：配置Service会话亲和性

 kubectl patch svc mongodb-shard -n auto -p '{"spec":{"sessionAffinity":"ClientIP","sessionAffinityConfig":{"clientIP":{"timeoutSeconds":10800}}}}'