はmicroservices

Question

から票を組み合わせることは、それは意味を成さないし、何が次のことを実現するための合理的な方法のようになります。

これは、単一のインスタンスまたはデータの時系列のいずれかのために発生する可能性があります。データを消費するいくつかのマイクロサービス（例えばカフカから）があり、ある種の分類を実行し、バイナリ値または離散値を割り当てることができます。そのような「投票」の結果を合理的に組み合わせて、単一価値の結果を保存または提示することは可能ですか？

データと一致する別のマイクロサービスについて考えていますが（時系列の場合は何らかの識別子で）、結果が一定の期間内に表示されるはずですそれは少し非同期になります。

Answer 1

これに類似した例があります。このコードは、3つのサービスのセットによって検証された新しいオーダーを送信し、その結果を照会するためのインターフェースを提供します。

注文は、3つの異なるマイクロサービスによって検証されます。それぞれが合格を出すか、検証が合格するかどうかについて失敗する。受注サービスに戻ると、Kafka Streamsジョブは検証結果を収集し、全体的な合格または合格を集計します。

https://github.com/confluentinc/kafka-streams-examples/tree/4.0.0-post/src/main/java/io/confluent/examples/streams/microservices

https://www.confluent.io/blog/building-a-microservices-ecosystem-with-kafka-streams-and-ksql/

このモデルでは、あまりにもあなたのユースケースのために働く必要があります。