我创建了一个Kafka连接器,用于阅读我的Mongo数据库集合的更改事件。我已将其设置为在发生任何更改时返回完整文档。对于新文档的创建和更新,它工作得很好。我正在接收这些事件。但在删除文档的情况下,我没有收到任何事件。如何从连接器获取文档删除事件?(我不知道还有什么要补充的。让我知道如果需要更多的细节)
0md85ypi1#
Debezium可以返回删除操作。我不确定官方的MongoDB源连接器是否可以
1条答案
按热度按时间0md85ypi1#
Debezium可以返回删除操作。我不确定官方的MongoDB源连接器是否可以