我有一个kafka主题接收实体上的有序更新,因此我使用最新的\u by \u偏移量构建了一个ksql物化视图,以便能够查询给定键的实体的最新更新。
现在我想让一个主题只存储在具体化视图上执行的更改,例如给定以下消息序列:
TOPIC:
key=1, value=A (new msg)
key=1, value=A (no change)
key=1, value=A (no change)
key=1, value=B (change)
我想收到关于目标主题的邮件:
key=1, value=A (new msg)
key=1, value=B (change)
我认为用物化视图创建的changelog主题的行为方式是这样的,但显然它正在发出每个事件,而不仅仅是反映键上的更改的事件。
如何才能做到这一点?
暂无答案!
目前还没有任何答案,快来回答吧!