消息路由监控

消息路由需要关注的一些信息,诸如消息同步TPS,消息延迟,消息堆积量,最新同步时间等

消息路由监控

消息路由需要关注的一些信息,诸如消息同步TPS,消息延迟,消息堆积量,最新同步时间等

消息路由需要关注的一些信息

采集信息项

内容说明

消息同步 TPS

每分钟统计一次消息同步的 TPS 值

消息延迟

当前同步到的位点和最新消息位点之间的时间差

消息堆积量

当前还没有来得及同步的消息数量

最新同步时间

最近一次消息同步发生的时间

对于获取并统计上面监控部分的信息,可以在OpenMessaging Runtime中通过Source/Sink Task中的接口方法—poll()/put(),进行监控项的计算,计算后再将这些信息进行持久化同步(通过“.Json”文件保存持久化),并回发给RMQ的Source集群的系统默认Topic(这里也需要再去定义一个系统默认Topic)。

Last updated