apache-kafka - Kafka Streams Processor API：直接写入kafka statestore，然后写入topic以避免延迟

我有一个生成主题的应用程序。在同一个应用程序中，我查询其物化状态存储以获取特定键的最新值。

一旦数据生成到主题，我必须立即查询状态存储。大多数时候，交互式查询返回旧值，因为更新状态存储中的值需要一些时间。

我正在考虑更改架构，我想知道是否可以先直接写入状态存储，然后再写入最终主题，以便我可以在更新值可用时立即获得它。如果这是可能的并且说我有同一个应用程序的多个实例，我如何查询其他实例的本地状态存储，因为我可能没有源流？

我知道交互式查询在带有源主题的 Kafka 流之上工作。但就我而言，如果我直接写入 statestore，rpc 会起作用吗？我该如何实现呢？

任何帮助深表感谢。

标签： apache-kafkaapache-kafka-streams