如何解决带有 kafka 和 mongoDB 连接器的发件箱模式
我想使用 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 连接器并实现了我们的发件箱模式。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
