我的samza job有很多任务，每个任务的嵌入式存储中都有一些状态。我想通过某种rpc机制向外界公开这个存储以供阅读。最好的解决办法是什么？
samza文档中有一段关于它的内容：

Samza does not currently have an equivalent API to DRPC, 
but you can build it yourself using Samza’s stream 
processing primitives.

我想到的唯一解决方案是，除了正常的处理之外，让我的任务在一个特殊的请求主题上使用具有一些相关id的请求消息，并将具有相同相关id的响应消息放入特殊的响应主题中。所以这就像Kafka的rpc解决方案，在我看来是次优的。
欢迎有任何想法！