如何处理Kafka(或任何其他类似的平台)在一个系统,不能容忍滞后滞后滞后滞后?

vmdwslir  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(207)

参与者:
kafka:保存源系统中已发布的事件。
服务a:使用事件。用于计算值并保存在其数据库中。
客户机:查询返回该值的服务a。
脚本:
如果服务延迟使用事件,它将延迟更新其数据库中的值。同时,客户机查询服务。虽然理想情况下,客户机应该已经获得计算出的新值(因为事件已经由源系统发布到kafka),但是由于服务a中的延迟,它将接收不正确的值。
Kafka能用在这样的流动中吗?如果是,我们如何处理给定的场景?
我了解,在监控 Jmeter 板这样的系统中,延迟使用来自kafka的(日志)消息可能会导致任何查看 Jmeter 板的人获得不正确的数据,但 Jmeter 板一旦开始使用来自kafka的消息,数据就会按照正确的时间绘制。
一些其他系统可以为消耗时间的延迟定义阈值,超过该阈值,将对kafka消息采取的操作可能被丢弃(就像一个通知系统,它需要通知用户某个产品已恢复库存)。
但是我的问题是这样的情况呢?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题