我正在尝试将合流的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
}
}
暂无答案!
目前还没有任何答案,快来回答吧!