当我们在 kafka 流中的两个 KTable 之间进行外键连接时生成的主题答案

【问题标题】：Topics generated when we do a foreign key join between two KTables in kafka streams当我们在 kafka 流中的两个 KTable 之间进行外键连接时生成的主题
【发布时间】：2021-01-26 08:33:47
【问题描述】：

当我们在 kafka 流中的两个 KTable 之间进行外键连接时，会生成哪些主题？它们包含哪些所有数据？

【问题讨论】：

标签： apache-kafka apache-kafka-streams

【解决方案1】：

对于 Kafka Streams 应用程序，您可以观察到两种类型的中间主题：-repartition 和 -changelog。

-repartition 主题在您的 Kafka Streams 应用程序调用更改密钥的命令时需要。

-changelog 主题表示更改日志状态（当您创建 KTables 时），其中流中的每个数据记录都捕获表的状态更改。请参阅duality-of-streams-and-tables 了解更多信息。

【讨论】：

谢谢基库利科夫。当我加入时，我还会收到 x-subscription-response-topic、x-subscription-registration-topic 之类的主题。它包含哪些数据？任何想法？对我来说，我的问题是 x-subscription-response-topic 主题包含的数据是 x-subscription-registration-topic 的两倍。如果您有任何想法，请告诉我。