问KSQL - Join不相等分区流
EN

Stack Overflow用户

提问于 2019-01-09 05:10:19

回答 1查看 581关注 0票数 1

如何在KSQL中加入数量不等的持有流的分区，并增加分区？

示例Stream-1具有3个分区，而Stream-2具有2个分区。在这种情况下，我们当然可以增加Stream-1 as 3 join的分区数量。但是我想知道，有没有其他方法可以通过KSQL连接不相等的分区流？

发布于 2019-01-09 05:57:30

不，不幸的是，KStream/KSQL不支持不相等分区主题的连接。

在调用join操作之前，两个主题必须具有相同数量的分区，这是一个前提条件，否则将失败。

为了保证共同分区，可以使用PARTITION_BY子句创建新的流：

CREATE STREAM topic_rekeyed WITH (PARTITIONS=6) AS SELECT * FROM topic PARTITION BY topic_key;

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/54099763

复制

相似问题

问KSQL - Join不相等分区流EN