我的应用程序有三个主题，它们接收一些属于用户的事件：
Event Type A -> Topic A
Event Type B -> Topic B
Event Type C -> Topic C
这将是消息流的一个示例：
Message(user 1 - event A - 2020-01-03)
Message(user 2 - event A - 2020-01-03)
Message(user 1 - event C - 2020-01-20)
Message(user 1 - event B - 2020-01-22)
我希望能够生成包含每个用户每月事件总数的报告，聚合来自三个主题的所有事件，例如：
User 1 - 2020-01 -> 3 total events
User 2 - 2020-01 -> 1 total events
拥有三个 KStreams（每个主题一个），我如何每月执行此添加以汇总来自三个不同主题的所有事件？你能显示这个的代码吗？
因为您只对计数感兴趣，所以最简单的方法是将 user-id 作为键，并为 each 保留一些虚拟值KStream，合并所有三个流并在之后进行窗口计数（请注意，不支持基于日历的窗口开箱即用；您可以使用 31 天窗口作为近似值或构建自己的自定义窗口）：
// just map to dummy empty string (note, that `null` would not work
KStream<UserId, String> streamA = builder.stream("topic-A").mapValues(v -> "");
KStream<UserId, String> streamB = builder.stream("topic-B").mapValues(v -> "");
KStream<UserId, String> streamC = builder.stream("topic-C").mapValues(v -> "");
streamA.merge(streamB).merge(streamC).groupByKey().windowBy(...).count();
您可能还对suppress()运算符感兴趣。