him*_*ims 0 apache-kafka apache-kafka-streams
我正在尝试使用处理器 api 创建 kafka 流，因为我有自定义流程。当我的处理器列出具有不同分区数量的多个主题时，我遇到了问题。我意识到我需要创建一个全球状态商店。我需要知道如何在监听多个主题的同时添加处理器并添加全局状态存储？
任何代码示例或链接都会有所帮助。谢谢你！！
全局状态存储只能读取单个主题。但您可以为每个主题创建一个全局商店。此外，全局存储不需要添加到任何处理器，并且可以被所有处理器自动访问。
我们的示例存储库应该有所帮助：https ://github.com/confluenceinc/kafka-streams-examples
另请查看文档： http: //docs.confluence.io/current
| 归档时间： |
|
| 查看次数： |
5799 次 |
| 最近记录： |