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