如何加入 Kafka KStream 到 Kstream of 3 Topics.

Question

我有3个主题："开始"，"继续"和"结束"这三个主题需要加入到一个主题消息中，我可以在其中获得作为 3 个主题消息组合的结果模型。

有许多示例显示了如何连接 2 个主题。如果有人可以给我一个例子或提示，说明我如何加入或这 3 个主题。

Answer 1

在实现 cogroup 功能之前，您需要首先将前 2 个主题合并为一个中间主题，然后将该主题与第三个主题合并。

有关如何执行此操作的示例，请参阅同组 KIP。

Answer 2

这取决于你想做什么样的加入。正如您所说，您有 KStream ，您将执行两个连续的窗口连接：

KStream stream1 = builder.stream(...);
KStream stream2 = builder.stream(...);
KStream stream3 = builder.stream(...);
KStream joined = stream1.join(stream2, ...)
                        .join(stream3, ...);