如何配置更新事件(mongo连接器)上发送的debezium字段

Question

我想使用debezium mongo连接器：

->从mongo获取事件

->把他们放进我的卡夫卡

->读卡夫卡

我的问题是，当debezium从mongo获取更新事件时，它只发送更新的字段：

此集合上的update change事件的值实际上将具有完全相同的模式，其有效负载的结构将相同，但包含不同的值。具体来说，update事件将不具有after值，而是有一个包含幂等更新操作的JSON表示的补丁字符串。

我想知道我是否可以以某种方式配置它，因为我想通过更新事件获得一些字段。

Answer 1

您应该能够使用Kafka流来解决这个问题--以类似(简化)的方式，就像在本例中的https://debezium.io/blog/2018/03/08/creating-ddd-aggregates-with-debezium-and-kafka-streams/一样。