仅在Confluent KSQL中的表/实例化视图更改上发出消息

问题描述

我有一个Kafka主题，该主题接收有关实体的有序更新，因此我使用 LATEST_BY_OFFSET 建立了 KSQL实体化视图，以便能够查询实体的最新更新，给定密钥。

现在，我希望有一个主题，该主题仅存储在该实例化视图上执行的更改，因此例如给出以下消息顺序：

TOPIC:
key=1,value=A (new msg)
key=1,value=A (no change)
key=1,value=B (change)

我希望收到有关目标主题的信息：

key=1,value=B (change)

我认为用实例化视图创建的 changelog主题的行为方式是这样的，但是显然正在发出每个事件，不仅是反映键更改的事件。

如何实现呢？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）