0

我们想在 Kafka 流应用程序中使用 GlobalKTable。输入主题（KTable/KStream）有 N 个分区，一个 GlobalKTable 将用作流应用程序中的字典。

GlobalKTable 的输入主题是否必须与其他输入主题（KTable/KStream 的来源）具有相同数量的分区？

据我了解，答案是否定的（不受限制，主题也可能有 M 个分区，其中 N > M），因为 GlobalKTable 在流应用程序的每个实例中都已完全加载，并且在 KStream 加入期间不需要共同分区手术。但我需要专家的确认！

谢谢！

4

1 回答 1

2

不，KStream 和 GlobalTable（连接）的主题分区数可能不同。

来自 Kafka Streams 开发者指南

在高层次上，KStream-GlobalKTable 连接与 KStream-KTable 连接非常相似。但是，与分区表相比，全局表以一定的代价为您提供了更大的灵活性：

  • 它们不需要数据共同分区。

更多详情可在这找到：

全局表连接

加入共分区要求

于 2020-12-14T14:47:21.067 回答