更新时间:2024-11-18 GMT+08:00

DMS仪表盘模板

分布式消息服务Kafka版(Distributed Message Service for Kafka)是一款基于开源社区版Kafka提供的消息队列服务,向用户提供计算、存储和带宽资源独占式的Kafka专享实例。重平衡日志记录Rebalance的详情,包括Rebalance时间、原因和触发Rebalance的客户端等。

云日志服务支持日志采集向导一站式采集DMS重平衡日志,支持多维度分析,并为DMS-Rebalance日志配置结构化和仪表盘。该仪表盘主要展示DMS重平衡日志的重平衡消费组个数、重平衡次数、消费组重平衡次数、重平衡原因及组详情。

前提条件

DMS重平衡日志中心

  1. 登录云日志服务控制台。
  2. 在左侧导航栏中选择“仪表盘 ”。
  3. 在仪表盘模板下方,选择“DMS仪表盘模板 > DMS重平衡日志中心”,查看图表详情。

    • 消费组ID,所关联的查询分析语句如下所示:
      select distinct("message.groupId")
    • 过滤重平衡原因。
    • 重平衡消费组个数图表所关联的查询分析语句如下所示:
      select count(distinct("message.groupId"))  as "total" from log where ("message.type"!='RESPONSE' and "message.type" !='REQUEST')
    • 重平衡次数图表所关联的查询分析语句如下所示:
      select count(*) as 'total'  where ("message.type" !='RESPONSE' and "message.type" !='REQUEST')
    • 消费组重平衡次数图表所关联的查询分析语句如下所示:
      select "message.groupId" as 'GroupId', count(*) as 'Count' where ('message.type' !='RESPONSE' and 'message.type' !='REQUEST')  group by "message.groupId"
    • 重平衡原因及组详情图表所关联的查询分析语句如下所示:
      select __time  as 'Time', "message.type" as 'Type' ,"message.groupId" as 'GroupId', "message.reason" as 'Reason',"message.group" as 'Group' where ('message.type' !='RESPONSE' and 'message.type' !='REQUEST')