kafka 流处理器 api 全局状态存储多个主题

kafka stream processor api Global state store multiple topics

我正在尝试使用处理器 api 创建一个 kafka 流，因为我有自定义进程。当我的处理器正在列出具有不同分区数量的多个主题时，我遇到了一个问题。我意识到我需要创建一个全球状态存储。我需要知道如何在监听多个主题时添加处理器和全局状态存储？

任何代码示例或链接都会有所帮助。谢谢！！

全局状态存储只能读取单个主题。但是您可以为每个主题创建一个全局存储。此外，全局存储不需要添加到任何处理器，所有处理器都可以自动访问。