小编him*_*ims的帖子

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

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