4

私はいくつかのタスクを含む samza ジョブを持っています。それぞれのタスクは、組み込みストアに何らかの状態を保持しています。このストアを公開して、ある種の RPC メカニズムを介して外の世界に読み取りたいと考えています。これに対する最善の解決策は何ですか？

それに関するSamzaドキュメントの1つの段落を次に示します。

Samza には現在、DRPC に相当する API がありません。
ただし、Samza のストリームを使用して自分で構築できます
処理プリミティブ。

私の頭に浮かぶ唯一の解決策は、通常の処理に加えて、特別な要求トピックでいくつかの相関 ID を持つ要求メッセージを消費し、同じ相関 ID を持つ応答メッセージを特別な応答トピックに入れることです。つまり、RPC-over-Kafka ソリューションのようなもので、最適とは思えません。

どんな考えでも大歓迎です！

4

1 に答える 1

0

私が覚えている限り、埋め込みストアは Kafka トピックでバックアップされています。ストアに何かを設定すると、トピックにメッセージが生成されます。したがって、このトピックを使用して、埋め込みストアを別のデータベースに「複製」できます。その後、データベースにクエリを実行できます。または、組み込みストアの代わりにデータベースのみを使用することもできます。しかし、このアプローチは、Samza ジョブでパフォーマンスの問題を引き起こす可能性があります...

于 2015-08-25T21:16:59.980 に答える