mongodb - Debezium Kafka 连接器 mongodb

Question

有什么方法可以向 kafka 连接器指定 mongo 上的哪些操作应该考虑。实际上，我不希望 kafka 在删除 mongo 文档时做任何事情（应该考虑更新和插入新文档）。
谢谢

Answer 1

您可以编写一个可以过滤掉不需要的操作的 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/示例/发件箱/routingsmt/EventRouter.java#L44