Kafka流api在Kstream和Ktable之间连接

Question

我有一个应用程序从一个主题多分区读取kstream，而从另一个主题多分区读取ktable。所以Kstream &Ktable将引用两个不同主题中的同一个分区或两个不同主题中的任何分区

Answer 1

首先，它们必须是共分区的(相同数量的分区)。Kafka Streams会检查它，或者在启动时抛出异常。

其次，你应该确保生产者在这些输入主题(KStream和KTable)上发送相同键的记录到相同的分区，这样消费者(使用join运算符的Kafka Streams应用程序)将永远看到任何匹配并且join成功。