我们想在kafka streams应用程序中使用globalktable。输入主题（ktable/kstream）有n个分区，一个globalktable将在流应用程序中用作字典。
globalktable的输入主题是否必须与其他输入主题（ktable/kstream的源）具有相同数量的分区？
据我所知，答案是否定的（它不受限制，主题也可能有m个分区，其中n>m），因为globalktable在流应用程序的每个示例中都是完全加载的，并且在kstream join操作期间不需要共分区。但我需要Maven的确认！
谢谢您！
1条答案
按热度按时间c7rzv4ha1#
不，kstream和globaltable（即join）主题的分区数可能不同。
来自kafka streams开发者指南
在高层，kstream globalktable联接与kstream ktable联接非常相似。但是，与分区表相比，全局表以一定的代价提供了更大的灵活性：
它们不需要数据共分区。
更多详情请参见：
全局表联接
连接共分区要求