mongodb - 带有 kafka 和 mongoDB 连接器的发件箱模式
问题描述
我想使用Mongo-Kafka 连接器在我们的微服务中实现发件箱模式,在我的发件箱(一个 MongoDB 集合)中,我使用以下字段存储主题数据:
, , , , 。kafka_topic
kafka_key
kafka_value
kafka_header_keys
kafka_header_values
但是我应该如何配置 mongo-kafka 连接器以从字段中动态选择主题kafka_topic
以及来自其他发件箱字段的值和标题?我无法从其配置参考中找到执行此操作的设置。
我还在考虑从 mongo-kafka 连接器存储库中获取一个分支,并使用我的自定义实现对其进行扩展。
如果您能帮助我,我将不胜感激。
解决方案
好的,我得到了答案,mongo-kafka 连接器不支持发件箱模式。对于其他数据库,Debezium 具有为我们执行此操作的Outbox 事件路由器,但在编写此答案之前它不支持 MongoDB 连接器。
作为最终答案:我们分叉了 mongo-kafka 连接器并实现了我们的发件箱模式。
推荐阅读
- ios - 用户在 Firebase 上使用 Google 登录后,如何在 swiftUI 中重新呈现我的视图?
- android-studio - 更新 Android Studio 时出现 Flutter 错误,Kotlin、Flutter、Dart 插件与新的 Android Studio 4.0 版本不兼容
- css - 如何制作可以在鼠标悬停时单独更改大小的导航栏?
- c# - 达到最大连接限制时如何更改 http.sys Web 服务器响应
- c# - 具有无限循环和 thread.sleep 高 CPU 使用率的多个线程
- flask - 我在理解 Flask 中的 UserMixin 时遇到问题
- r - R中的.Rnw文件和块的问题
- mysql - Ubuntu 18.04 部署 zabbix4.0 时,数据库类型是 PostgreSQL 而不是 MySQL。如何设置它以支持 MySQL?
- c# - 为什么添加 Mesh Collider 会使 Inverse Kinematic 腿打乱他们的运动?
- python - 即使我设置种子变量,为什么 TensorFlow 会产生不同的输出?