Kafka connectr mongoDB源代码的工作示例?

toiithl6  于 12个月前  发布在  Go
关注(0)|答案(1)|浏览(90)

我不能让它工作。
下面是我的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权限。

bjp0bcyl

bjp0bcyl1#

首先检查您在“connection.uri”中使用的用户是否具有在MongoDB中执行changeStream操作所需的权限。
您尝试执行的操作(“change.stream.full.document”:“updateStream”)需要changeStream操作。
尝试将权限添加到用户或使用具有必要权限的其他用户,如root

相关问题