Debezium无法认证MongoDB分片集群，aggregate命令未授权求助

报错显示Debezium在访问分片节点（192.168.2.5:27023、192.168.2.4:27020）执行aggregate命令时未授权，虽然连接的是mongos（27030端口）且使用了root用户，但问题核心出在分片集群的认证传递与拓扑发现环节：

• directConnection=true会强制驱动仅连接指定mongos节点，Debezium无法自动发现分片集群拓扑，导致访问分片节点时认证信息未正确传递
• 即使是root用户，若集群用户同步异常，分片节点可能无法识别该用户权限

1. 修改连接字符串，移除directConnection=true #

分片集群场景下，MongoDB驱动需要自动发现集群拓扑并传递认证信息到所有节点，修改后的连接字符串：

"mongodb.connection.string":"mongodb://user2:1@192.168.2.5:27030/?authMechanism=SCRAM-SHA-256&authSource=admin"

2. 确认用户为集群级root用户 #

通过mongos连接集群，执行以下命令验证用户权限：

use admin
db.getUser("user2")

确保返回的roles包含{ "role": "root", "db": "admin" }，该角色为集群级权限，可访问所有分片节点。

3. 验证分片节点的用户同步状态 #

登录任意分片节点的mongod，执行：

use admin
db.getUser("user2")

若无法找到用户，说明集群用户同步异常，可重启分片节点的mongod服务，触发从config库同步用户信息。

4. （可选）临时调整capture模式排查 #

若上述步骤无效，可先将capture.mode改为change_streams（不启用pre-image），测试是否能正常认证：

"capture.mode": "change_streams"

如果此模式正常，再排查pre-image相关配置（root用户默认已具备changeStream和find权限，可覆盖pre-image需求）。

5. 检查容器网络连通性 #

确保Debezium容器能访问到所有分片节点的端口（27020、27023），容器化部署下的网络隔离可能导致Debezium无法正常连接分片节点完成认证。

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