rocketmq-connector
  • Message Connector 简介
  • 架构设计
    • Woker
    • Runtime
    • Connector
    • Routing Task
    • 消费位点同步
    • 消息路由监控
  • Quick Start
    • 前期准备
      • RocketMQ单机环境
      • RocketMQ集群搭建
    • RocketMQ Runtime
    • File Connector
  • RocketMQ Connect
    • RocketMQ Connect 简介
    • 应用场景
    • RocketMQ Runtime
      • 启动流程
      • Runtime 参数配置
      • RESTful 接口
      • Connector生命周期
      • 负载均衡
    • RocketMQ Console
      • Console 简介
      • 安装和使用
      • 使用指南
  • RocketMQ Connector
    • RocketMQ Replicator
      • Replicator简介
      • Replicator快速开始
      • Replicator 参数配置
    • Connect-Mongo
    • Connect-MySQL
    • Connect-Redis
  • 开发者中心
    • RELEASE NOTE
    • mqadmin 操作指南
    • 最佳实践
    • 工业实践
      • connector-mongo实践
  • 贡献者指北
    • 参与告知
    • 文档贡献指北
    • 本地调试向导
    • 一个简单Connector的实现
    • Contributor二三言
Powered by GitBook
On this page

Was this helpful?

  1. 架构设计

消息路由监控

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

消息路由监控

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

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

采集信息项

内容说明

消息同步 TPS

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

消息延迟

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

消息堆积量

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

最新同步时间

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

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

Previous消费位点同步Next前期准备

Last updated 5 years ago

Was this helpful?