我想使用 debezium mongo 连接器来：
-> 从 mongo 获取事件
-> 把它们放进我的卡夫卡
-> 从卡夫卡读取
我的问题是，当 debezium 从 mongo 获取更新事件时，它只发送更新的字段：
此集合上的更新更改事件的值实际上将具有完全相同的架构，其有效负载的结构将相同但将包含不同的值。具体来说，更新事件不会有 after 值，而是会有一个包含幂等更新操作的 JSON 表示的补丁字符串。
我想知道我是否可以以某种方式配置它，因为我想通过更新事件获得一些字段。
问问题
519 次
1 回答
0
您应该能够使用 Kafka Streams 解决问题 - 以与本例中类似（简化）的方式https://debezium.io/blog/2018/03/08/creating-ddd-aggregates-with-debezium-and -卡夫卡流/
于 2019-01-02T10:03:05.777 回答