您可以使用从所有分区获取数据的全局存储。
从文件来看，
将全局状态存储添加到拓扑。statestore从提供的输入主题的所有分区中获取数据。每个kafka streams示例将正好有一个statestore示例。
语法如下：

public StreamsBuilder addGlobalStore(StoreBuilder storeBuilder,
                                     String topic,
                                     Consumed consumed,
                                     ProcessorSupplier stateUpdateSupplier)

最后一个论点是 ProcessorSupplier 它有一个 get() 返回一个 Processor 将对每个新消息执行。这个 Processor 包含 process() 方法，该方法将在每次向主题发送新消息时执行。
全局存储是针对每个流示例的，因此您可以获得每个流示例中的所有主题数据。
在这个过程中（k键，v值），您可以编写您的处理逻辑。
全局存储可以是内存中的，也可以是持久的，并且可以由changelog主题支持，这样即使streams示例本地数据（state）被删除，也可以使用changelog主题构建存储。