2

我想使用Mongo-Kafka 连接器在我们的微服务中实现发件箱模式，在我的发件箱（一个 MongoDB 集合）中，我使用以下字段存储主题数据： , , , , 。kafka_topickafka_keykafka_valuekafka_header_keyskafka_header_values

但是我应该如何配置 mongo-kafka 连接器以从字段中动态选择主题kafka_topic以及来自其他发件箱字段的值和标题？我无法从其配置参考中找到执行此操作的设置。

我还在考虑从 mongo-kafka 连接器存储库中获取一个分支，并使用我的自定义实现对其进行扩展。

如果您能帮助我，我将不胜感激。

4

2 回答 2

2

好的，我得到了答案，mongo-kafka 连接器不支持发件箱模式。对于其他数据库，Debezium 具有为我们执行此操作的Outbox 事件路由器，但在编写此答案之前它不支持 MongoDB 连接器。

作为最终答案：我们分叉了 mongo-kafka 连接器并实现了我们的发件箱模式。

于 2021-01-01T16:32:31.683 回答
0

我为 MongoDB 功能的发件箱事件路由器做了一个 PR ，它昨天刚刚合并！(2021.11.17)。所以，我相信这个功能会在不久的将来应用。它支持与现有发件箱事件路由器相同的功能。但是，您还必须使用多文档事务。但是，它计划在未来开发没有多文档事务。

于 2021-11-18T09:12:08.550 回答