FAQ-Mongodb写kafka任务认证异常

问题描述/异常栈

Mongodb写kafka任务认证异常
FAQ-Mongodb写kafka任务认证异常 - 图1

解决方案

现象:MongoDB CDC连接器无法通过用户名和密码访问MongoDB数据库,出现用户名或密码无效的错误提示。其他组件可以通过用户名和密码访问MongoDB数据库。为什么?
原因:发生此错误是因为用户凭据是在特定数据库下创建的。如果要访问MongoDB数据库,请添加connection。options' = ‘authSource=用户所属的数据库’到WITH子句。
解决方法: 在自定义参数处,配置mongodb的 connnection.options,指定要认证的db,具体示例如下:
source.connection.options authSource=test_db db替换为自己实际的db FAQ-Mongodb写kafka任务认证异常 - 图2

作者:焦巍