apache-kafka Ksql -来自具有不同分区号的主题的流

s3fp2yjn  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(203)

我正在尝试使用ksqlDB连接来自2个不同Kafka主题的消息,这2个主题具有不同的分区号。当我从每个主题创建流并尝试连接它们时,ksqlDB不允许在基本主题中连接不同的分区号。
当我为每个主题做以下步骤:- 〉从根主题创建流,-〉从第一个流创建另一个流,新的主题有1个分区(减少4到1)我在有1个分区的最后一个流上看不到任何数据。
ksqlDB中有没有连接两个分区号不同的主题的解决方案?

kyks70gy

kyks70gy1#

我也遇到了同样的问题。问题不是分区的数量。问题是连接的字段具有不同的数据类型(bigint和double)。

相关问题