我们正在用datamountaineer类配置kafka接收器连接器,以获取upsert功能(插入/更新),但我们面临以下错误
--错误
**NoSuchMethodFound**
--配置
connector.class=com.datamountaineer.streamreactor.connect.mongodb.sink.MongoSinkConnector
tasks.max=1
topics=orders-topic
connect.mongo.kcql=INSERT INTO orders SELECT * FROM orders-topic
connect.mongo.db=connect
connect.mongo.connection=mongodb://localhost:27017
connect.mongo.batch.size=10
暂无答案!
目前还没有任何答案,快来回答吧!