【问题标题】:KTable-KTable Foreign-Key Join SemanticsKTable-KTable 外键连接语义
【发布时间】: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


【解决方案1】:

是的,这是文档中的错误。 ——谢谢你的呼唤。我们会修复它。

顺便说一句:如果您在文档中遇到错误,请随时发送电子邮件至 docs@confluent.io,以便我们修复它们!

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2021-12-03
    • 2022-01-09
    • 2020-11-03
    • 1970-01-01
    相关资源
    最近更新 更多