mongodb - 带有 MongoDB sink 连接的 Confluent Cloud 无法正常工作

Question

我正在尝试将 confluent kafka connect 与 mongodb sink 连接，但它没有按预期工作，它会引发空指针异常。

我的融合开发环境在 GCP VM 实例中运行。

并安装了“confluent-hub install mongodb/kafka-connect-mongodb:latest”

以下是我的接收器配置。

{
 "name": "today-menu-sink",
 "config": {    
      "connector.class":"com.mongodb.kafka.connect.MongoSinkConnector",
      "tasks.max":"1",
      "topics":"newuser",
      "connection.uri":"mongodb+srv://*********************.mongodb.net",
      "database":"BigBoxStore",
      "collection":"users",
      "key.converter":"org.apache.kafka.connect.json.JsonConverter",
      "key.converter.schemas.enable":false,
      "value.converter":"io.confluent.connect.avro.AvroConverter",
      "value.converter.schema.registry.url" : "http://*******:8081" ,
      "value.converter.schemas.enable":true
      }
}

标签： mongodbapache-kafkaconfluent-platformsink