它是否有意义,实现以下内容的合理方式是什么:
这可能发生在单个实例或数据的时间序列中。可能有几个微服务使用数据(例如来自kafka ),并执行某种分类并分配二进制值或离散值。我们如何合理地组合这种“投票”的结果,以保存或显示单值结果。
我正在考虑另一个微服务,它将匹配数据(在按某个标识符的时间序列的情况下),但它需要知道预期有多少投票,或者可以假设结果应该在某个时间范围内出现,但随后它变得不那么异步。
发布于 2018-01-02 13:39:15
下面有一个例子,它做了类似的事情。该代码提供了一个用于提交新订单的接口,通过一组三个服务对其进行验证,然后查询结果。
订单由三种不同的微服务进行验证。对于验证是否通过,每个函数都发出一条通过或失败的消息。回到Orders Service中,Kafka Streams作业收集验证结果,并汇总总体通过或失败。
https://www.confluent.io/blog/building-a-microservices-ecosystem-with-kafka-streams-and-ksql/
这个模型也应该适用于你的用例。
https://stackoverflow.com/questions/47915099
复制相似问题