发布时间:2021-02-26 10:46:43
最近有个项目需求,有个数据转发服务,需要从kafka消息队列消费数据,然后转发到rabbitmq。要求转发数据不重复,且不能丢失数据。这里主要考虑转发的目的地址网络异常时,数据不能送达情况,当网络恢复时,要接着异常前发送的记录继续发送。 要来实现此功能,需要先清楚kafka消费原理: kakfa用offs.........【阅读全文】
发布时间:2021-02-25 19:12:54
问题描述1、 测试反馈,设备有上报的数据,但管理页面显示设备状态离线分析思路:1、由于这个状态显示是实时计算的,之前业务判断逻辑是,当上报时间与当前系统处理时间超过15分钟,则认为设备异常。而当前设备上报是正常的,那么有可能是服务处理延迟。 分析过程:1、 查看kafka消息队列,发现消息队列.........【阅读全文】