apache-kafka - Kafka Stream API 在 Kstream 和 Ktable 之间加入

Question

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

标签： apache-kafkaapache-kafka-streams

Answer 1

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

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