小编bch*_*392的帖子

我有一个执行一些状态处理的微服务。应用程序从输入主题构建 KStream，进行一些状态处理，然后将数据写入输出主题。

我将在同一组中运行 3 个该应用程序。当微服务发生故障时，我需要存储 3 个参数，接管的微服务可以查询共享状态存储并从崩溃的服务停止的地方继续。

我正在考虑将这 3 个参数推送到状态存储中，并在其他微服务接管时查询数据。从我的研究中，我看到了很多人们使用状态存储执行事件计数的例子，但这并不完全是我想要的，有谁知道一个例子或者解决这个问题的正确方法是什么？