【发布时间】:2021-03-13 09:26:30
【问题描述】:
Confluent 网站的documentation 提到以下内容:
左边的KTable可以有多个记录映射到同一个key 正确的 KTable。可能会导致对单个左侧 KTable 条目的更新 在单个输出事件中,只要相应的键存在于 正确的KTable。 因此,对右侧 KTable 条目的一次更新 将导致更新左侧 KTable 中的每条记录 相同的外键。
看下面的例子说明:
根据解释,在右侧的内连接(10, baz) 的情况下,应该会触发左侧的两条记录,这些记录将被添加到结果连接表中。但在解释中,它不在表格中。这是一个错字吗?或者我错过了什么。
【问题讨论】:
-
从文档中我同意,在创建外键后,INNER JOIN 也应该产生更新
(q,10,baz),(r,10,baz)。但是,当处理(q,10)和(r,10)时外键10不存在时,可能在某处出现问题,内部连接认为它们已死。 -
你能分享一个代码 sn-p 你在两个 ktables 之间进行外键连接吗?我也想做同样的事情,但我无法自己实现。
标签: apache-kafka apache-kafka-streams