问题描述
我想使用 Mongo-Kafka 连接器 在我们的微服务中实现 发件箱模式,在我的发件箱(MongoDB 集合)中,我使用以下字段存储主题数据:
kafka_topic
、kafka_key
、kafka_value
、kafka_header_keys
、kafka_header_values
。
但是我应该如何配置 mongo-kafka 连接器以从 kafka_topic
字段中动态选择主题,以及其他发件箱字段中的值和标题?
我无法从其配置参考中找到执行此操作的设置。
我也在考虑从 mongo-kafka 连接器存储库获取一个 fork,并使用我的自定义实现对其进行扩展。
如果您能帮助我,我将不胜感激。
解决方法
好的,我得到了答案,mongo-kafka 连接器不支持发件箱模式。 对于其他数据库,Debezium 有 Outbox event router 可以为我们执行此操作,但在编写此答案之前它不支持 MongoDB 连接器。
作为最终答案:我们分叉了 mongo-kafka 连接器并实现了我们的发件箱模式。