我想访问数据流"A",检查一些条件与表"B“,最后更新状态的表"B”。
(A,B) ====> check conditions in B ====> finally update B
如何在卡夫卡流中实现相同的逻辑?从文档中我观察到,对于流数据"A“,我们可以使用Kstreams,而对于更新表"B”,我们可以使用Ktable。但是,只有kstreams和ktable之间允许的操作才是联接,并且它不更新ktable(相反,只使用它作为查找)。此外,它还创建了另一个新的kstream(我不想要)。简而言之,我想访问Ktable作为引用传