我的问题是-我有一个Kafka流处理微服务，它可以监听多个主题。聚合来自多个主题的状态，并将其存储在状态存储中。我们将聚合消息提前发送到下游系统。下游系统将在不同的Kafka主题上回复其他消息。需要创建全局状态存储，它对我的所有微服务实例都可见。使用全球商店在卡丁车上实现同样的目标可能吗？我可以获得如何创建一个示例代码吗？
引用自文档
在任何给定实例上本地可用的状态只是应用程序整个状态的子集。查询实例上的本地存储将只返回该特定实例上本地可用的数据。
在此实例中，要跨实例查询，必须公开application.server，如注释中的链接所述。同样相关的是：Kafka Stream StateStore在所有实例中是全局的还是仅在本地的？
但是，GlobalKTable拥有每个实例上所有数据的完整副本