kafka streams dsl或用于db changelog派生的处理器api

e0uiprwp  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(278)

我使用debezium从我的书店db中捕获4个表的变化,数据模型是一个eav结构(高度规范化)。
书:

书籍属性:

账面价值:

账面价值\u varchar…类似于账面价值\u int
我的目标是创建一个输出主题,当作为ktable使用时,它等效于:

我是流处理的新手,我尝试过使用ksdsl来加入主题。到目前为止,我的努力取得了不同程度的成功。这是更适合处理器api的操作类型吗?

暂无答案!

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

相关问题