【发布时间】：2019-07-22 12:37:14
【问题描述】：
有没有办法向kafka连接器指定mongo上的哪些操作应该考虑。实际上，我不希望 kafka 在删除 mongo 文档时做任何事情（应该考虑更新和插入新文档）。
谢谢
【问题讨论】：
标签： mongodb apache-kafka apache-kafka-connect debezium
【发布时间】：2019-07-22 12:37:14
【问题描述】：
您可以编写一个可以过滤掉不需要的操作的 SMT (https://cwiki.apache.org/confluence/display/KAFKA/KIP-66%3A+Single+Message+Transforms+for+Kafka+Connect)。一个示例是删除 delete 记录摘自此 SMT - https://github.com/debezium/debezium-examples/blob/master/outbox/event-routing-smt/src/main/java/io/debezium/examples/outbox/routingsmt/EventRouter.java#L44
【讨论】：