消息路由需要关注的一些信息,诸如消息同步TPS,消息延迟,消息堆积量,最新同步时间等
Last updated 5 years ago
消息路由需要关注的一些信息
对于获取并统计上面监控部分的信息,可以在OpenMessaging Runtime中通过Source/Sink Task中的接口方法—poll()/put(),进行监控项的计算,计算后再将这些信息进行持久化同步(通过“.Json”文件保存持久化),并回发给RMQ的Source集群的系统默认Topic(这里也需要再去定义一个系统默认Topic)。
采集信息项
内容说明
消息同步 TPS
每分钟统计一次消息同步的 TPS 值
消息延迟
当前同步到的位点和最新消息位点之间的时间差
消息堆积量
当前还没有来得及同步的消息数量
最新同步时间
最近一次消息同步发生的时间