开发者社区> 问答> 正文

LogHub消费组如何监?


ConsumerGroup 是一个消费者组,包含多个Consumer,每个Consumer消费Logstore中的一部分Shard。
Shard的数据模型可以简单理解成一个队列,新写入的数据被加到队尾,队列中的每条数据都会对应一个数据写入时间,下图是Shard的数据模型。

协同消费延迟报警中的基本概念:

  • [backcolor=transparent]消费过程:消费者从队头开始顺序读取数据的过程。
  • [backcolor=transparent]消费进度:消费者当前读取的数据对应的写入时间。
  • [backcolor=transparent]消费落后时长:当前消费进度和队列中最新的数据写入时间的差值,单位为秒。

ConsumerGroup的消费落后时长取其包含的所有Shard的消费落后时长的最大值,当超过用户预设阈值时,就认为消费落后太多,需要报警。

配置方法


  1. 登录 日志服务管理控制台,单击需要监控的 Logstore 的监控图标。

  2. 找到消费落后时长图表,单击进入云监控控制台。

  3. 该图展示了 Logstore 下所有 ConsumerGroup 的消费落后时长,单位为秒。红框中图例是所有的 ConsumerGroup,单击右上角 [backcolor=transparent]创建报警规则 进入规则创建页面。

  4. 创建针对 ConsumerGroup spamdetector-report-c 的报警规则,5min 内只要有一次延迟大于等于 600 秒就会报警。设置生效时间和报警通知联系人,保存规则。

上面的操作完成后便成功创建了报警规则。有关报警规则配置的任何问题,请提工单到云监控。

展开
收起
轩墨 2017-10-23 10:13:13 1904 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
基于RocketMQ Connect 构建全新数据流转处理平 立即下载
零基础实现Flume收集网站日志数据到MaxCompute 立即下载
腾讯TB级别的海量日志监控平台 立即下载