关于KStream - KTable
连接的问题。通常这种连接用于 KTable 提供参考数据的数据丰富目的。
所以问题是,当 KTable 记录得到更新时,我们如何去更新我们已经处理、丰富并可能存储在某个数据存储中的旧记录?
有没有我们可以遵循的模式?
(请假设KTable - KTable
不会是一个选项,因为KStream
side 会发出大量的变化)
关于KStream - KTable
连接的问题。通常这种连接用于 KTable 提供参考数据的数据丰富目的。
所以问题是,当 KTable 记录得到更新时,我们如何去更新我们已经处理、丰富并可能存储在某个数据存储中的旧记录?
有没有我们可以遵循的模式?
(请假设KTable - KTable
不会是一个选项,因为KStream
side 会发出大量的变化)