与mongodb sink connect合流的云不起作用

svgewumm  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(275)

我正在尝试将合流的kafka connect与mongodb sink连接起来,但是它没有按预期工作,它抛出了空指针异常。
我的合流开发环境正在gcp vm示例中运行。
并安装了“汇流集线器”安装mongodb/kafka连接-mongodb:latest"
下面是我的Flume配置。

{
 "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
      }
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题