如何解决MongoDB Kafka 连接器中的 delete.on.null.values 不起作用
我正在研究 MongoDB Kafka 连接器,我能够成功创建和更新记录,但无法删除连接器配置中的记录我正在使用此配置
{
"name": "mongo-sink","config": {
"connector.class": "com.mongodb.kafka.connect.MongoSinkConnector","tasks.max": "1","topics": "test","connection.uri": "mongodb://mongo1:27018,mongo2:27019,mongo3:27020","database": "accounting","collection": "test","key.converter": "org.apache.kafka.connect.storage.StringConverter","value.converter": "io.confluent.connect.avro.AvroConverter","value.converter.schema.registry.url": "http://schema-registry:8081","value.converter.schemas.enable": "false","document.id.strategy": "com.mongodb.kafka.connect.sink.processor.id.strategy.PartialKeyStrategy","document.id.strategy.partial.key.projection.list":"productId","document.id.strategy.partial.key.projection.type":"ALLOWLIST","writemodel.strategy":"com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy","delete.on.null.values": "true","transforms":"WrapKey","transforms.WrapKey.type":"org.apache.kafka.connect.transforms.HoistField$Key","transforms.WrapKey.field":"_id"
}
}
如果我发送空记录,则无法删除记录,文档被更新为空值而不删除任何想法?
解决方法
如 MongoDB Sink 文档中所述,
删除.on.null.values
布尔值
当值为空时,连接器是否应删除具有匹配键值的文档。
您必须以以下格式设置您的消息:
{"key" : "xyz","value" : null,... }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。