如何在Samza中實現類似於Storm DRPC的東西？

Question

我有一些任務的samza工作，其中每個任務都在其嵌入式商店中保存一些狀態。我想通過某種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的響應消息放入特殊的響應主題中。所以這就像RPC-over-Kafka解決方案，這在我看來並不理想。

歡迎任何想法！

Answer 1

據我記得，嵌入式商店是在卡夫卡話題中備份的。當您在商店中設置某些內容時，該消息將生成該主題。因此，您可以使用此主題，並且可以將嵌入式存儲「克隆」到不同的數據庫。然後你可以查詢數據庫。或者你可以使用數據庫而不是嵌入式商店。但是這種方法可能會導致Samza工作中的性能問題...