mongodb-kafka源连接器-管道未按预期工作

Question

我正试图将MongoDB中符合特定条件的文档推送给Kafka。当我没有为"；管道"；属性，我会把所有的文件推送给卡夫卡。当我添加一个配置来筛选匹配条件时，我不会得到任何配置。这是我的连接器配置：

name=MongoDBSourceConnector
tasks.max=1
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.storage.StringConverter
connection.uri=mongodb://myconnectionstring
database=mydb
collection=mycollection
publish.full.document.only=true
pipeline=[ { $match: { title: "mytitle"} } ]
copy.existing.pipeline=[ { $match: { title: "mytitle"} } ]
copy.existing=true

我正在遵循此文档：https://docs.mongodb.com/kafka-connector/current/kafka-source/我在Kafka连接器日志上没有错误。你知道我在这里做错了什么吗？

Answer 1

问题出在"；。MongoDb运算符应该没有引号，字段应该有引号：

pipeline=[ { $match: { "title": "mytitle"} } ]

copy.existing.pipeline=[｛$match:｛"title"："mytitle"｝｝]