我已经按照官方教程为我的 Kafka Connect MongoDB 源创建了一个配置,但它总是失败。当我检查控制中心时,主题列为 --
name=MongoDBSourceConnector
tasks.max=1
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
connection.uri=mongodb://user:pass@host:27017/
database=dummy
collection=xd
output.format.value=json
output.format.key=json
key.converter.schemas.enable=false
value.converter.schemas.enable=false
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
我的水槽工作正常。 谢谢