Kafka Stream API 在 Kstream 和 Ktable 之间加入

Question

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

Answer 1

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

其次，您应该确保生产者跨这些输入主题（KStream 和 KTable）将相同键的记录发送到相同分区，以便消费者（使用 join 的 Kafka Streams 应用程序operator) 将永远看到任何匹配并且join 成功。