仅对合流ksql中的表/物化视图更改发出消息

jqjz2hbq  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(297)

我有一个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主题的行为方式是这样的,但显然它正在发出每个事件,而不仅仅是反映键上的更改的事件。
如何才能做到这一点?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题