4

我有许多任务的 samza 工作，每个任务在其嵌入式存储中都有一些状态。我想通过某种 RPC 机制向外界公开这个商店以供阅读。什么是最好的解决方案？

这是 Samza 文档中关于它的一段：

Samza 目前没有与 DRPC 等效的 API，
但是您可以使用 Samza 的流自己构建它
处理原语。

我想到的唯一解决方案是让我的任务除了正常处理之外，在一个特殊的请求主题上消费具有一些相关 ID 的请求消息，并将具有相同相关 ID 的响应消息放入特殊的响应主题中。所以这就像 RPC-over-Kafka 解决方案在我看来不是最理想的。

欢迎任何想法！

4

1 回答 1

0

据我所知，嵌入式商店是在 Kafka 主题中备份的。当您在商店中设置某些内容时，会为主题生成消息。因此，您可以使用此主题，并且可以将嵌入式存储“克隆”到不同的数据库。然后就可以查询数据库了。或者您可以只使用数据库而不是嵌入式存储。但是这种方法可能会导致您的 Samza 工作出现性能问题......

于 2015-08-25T21:16:59.980 回答