我不能让它工作。
下面是我的json配置:
{
"name": "lastlook-mongodb-source-connector",
"config": {
"connector.class": "com.mongodb.kafka.connect.MongoSourceConnector",
"tasks.max": "4",
"connection.uri": "mongodb://user:pass@machine1:27017,machine2:27017/?authSource=admin",
"database": "DB",
"collection": "Collection",
"topic": "Topic",
"startup_mode": "copy_existing",
"pipeline":"[]",
"change.stream.full.document":"updateLookup",
"producer.override.sasl.mechanism": "SCRAM-SHA-256",
"producer.override.security.protocol": "SASL_PLAINTEXT",
"producer.override.sasl.jaas.config": "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"user\" password=\"pass\";"
}
}
但由于某种原因,我犯了一个错误:
{“error_code”:400,“message”:“连接器配置无效并包含以下1个错误:\n用户权限无效。缺少以下操作权限:changeStream\n还可以在端点/connector-plugins/{connectorType}/config/validate
“}上找到上述错误列表
一点都不清楚。
有这方面的信息吗?
编辑:
正如@Sara M.提到的,这是由于我用来连接数据库的mongodb“用户”缺乏特权。
您需要为该用户添加changeStream权限。
1条答案
按热度按时间bjp0bcyl1#
首先检查您在“connection.uri”中使用的用户是否具有在MongoDB中执行changeStream操作所需的权限。
您尝试执行的操作(“change.stream.full.document”:“updateStream”)需要changeStream操作。
尝试将权限添加到用户或使用具有必要权限的其他用户,如root。