0

关于KStream - KTable连接的问题。通常这种连接用于 KTable 提供参考数据的数据丰富目的。

所以问题是,当 KTable 记录得到更新时,我们如何去更新我们已经处理、丰富并可能存储在某个数据存储中的旧记录?

有没有我们可以遵循的模式?

(请假设KTable - KTable不会是一个选项,因为KStreamside 会发出大量的变化)

4

0 回答 0