apache-kafka - kafka mongo-db connector KCQL 支持配置--分布式

Question

我们正在使用 datamountaineer 类配置我们的 kafka sink 连接器以获取 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

标签： apache-kafkaapache-kafka-connect