我正在尝试使用ksqlDB连接来自2个不同Kafka主题的消息,这2个主题具有不同的分区号。当我从每个主题创建流并尝试连接它们时,ksqlDB不允许在基本主题中连接不同的分区号。
当我为每个主题做以下步骤:- 〉从根主题创建流,-〉从第一个流创建另一个流,新的主题有1个分区(减少4到1)我在有1个分区的最后一个流上看不到任何数据。
ksqlDB中有没有连接两个分区号不同的主题的解决方案?
我正在尝试使用ksqlDB连接来自2个不同Kafka主题的消息,这2个主题具有不同的分区号。当我从每个主题创建流并尝试连接它们时,ksqlDB不允许在基本主题中连接不同的分区号。
当我为每个主题做以下步骤:- 〉从根主题创建流,-〉从第一个流创建另一个流,新的主题有1个分区(减少4到1)我在有1个分区的最后一个流上看不到任何数据。
ksqlDB中有没有连接两个分区号不同的主题的解决方案?
1条答案
按热度按时间kyks70gy1#
我也遇到了同样的问题。问题不是分区的数量。问题是连接的字段具有不同的数据类型(bigint和double)。