KTable-KTable外键连接语义
Confluent网站的留档提到以下内容：
左侧KTable可以有多条记录，这些记录映射到右侧KTable上的同一个键。如果右KTable中存在相应的键，则对单个左KTable条目的更新可能会导致单个输出事件。因此，对右KTable条目的单个更新将导致对左KTable中具有相同外键的每个记录进行更新。
查看下面的示例说明：
根据解释，如果是内部联接，则右侧的（10，baz）应该触发左侧的两条记录，这两条记录将被添加到结果联接表中。但在解释中，它不在表格中。这是打字错误吗？或者我错过了什么。
共有1个答案
是的，这是文件中的一个错误。-谢谢你说出来。我们会修好它的。
顺便说一句：如果您在文档中遇到错误，请随时通过电子邮件docs@confluent.io，以便我们修复它们！
-
我正在尝试执行 KTable-KTable 外键联接，但我收到一个错误，因为 Kafka 流正在尝试对外键使用字符串 serde。 我希望它使用Kotlinx序列化服务器。如何指定？ 我想使用FK选择器将两个KTables的数据连接在一起，并将值重新映射到一个聚合对象中。 然而，我得到一个错误，因为Kafka Streams正在使用（我的默认Serde）用于反序列化外键。但它是一个JSON对象，我
-
我正在尝试通过键连接两个（无窗口）并将结果写入
-
我想加入一个 kstream:从主题创建，该主题具有JSON值。我使用值中的两个属性来重新键控流。示例值（json的片段）。我创建了自定义pojo类并使用自定义SERDES。 键映射为： 我查看了KStream并打印了键和我使用的属性。看起来都很好。 null 现在，当我执行内部连接并对主题进行窥视或通过/时，我看到键和值不匹配。Join似乎不起作用, 我有完全相同的东西通过ksql工作，但想做我
-
我找到的大部分信息都与主键连接有关。我知道外键连接对于Kafka流来说是一个相对较新的功能。我对它的规模感兴趣。我知道Kafka Streams并行性受到每个主题上的分区数的限制，但是我对增加输入主题分区意味着什么有一些疑问。 外键联接对共分区输入主题有相同的要求吗？也就是说，两个主题是否需要具有相同数量的分区 在应用程序在生产环境中运行数月或数年后，如何添加分区？支持每个KTable的chang
-
请参阅下面的更新以显示潜在的解决方案 我们的应用程序使用2个主题作为KTables，执行左连接，并输出到一个主题。在测试过程中，我们发现当我们的输出主题只有一个分区时，这项功能可以正常工作。当我们增加分区的数量时，我们注意到生成到输出主题的消息数量减少了。 在启动应用程序之前，我们用多个分区配置测试了这一理论。使用1个分区，我们可以看到100%的消息。使用2，我们可以看到一些消息（少于50%）。对
-
使用汇流5.4.1 在将连接的流从连接的KTable转发到另一个主题时，我们碰巧在新的KTable外键连接中遇到了一个问题。 将错误中提到的模式与在模式注册表上注册的模式进行比较，结果完全相同…似乎Kafka 2.4.0中已经出现了类似的问题:https://issues.apache.org/jira/browse/Kafka-9390并且该问题在转发到另一个主题时仍然存在