Kafka 资源管控
在接入云上 Kafka,发送消息,消费消息之后,您需要查看消息的运行状况。
[backcolor=transparent]注意:Kafka 目前的资源管控功能集成在
MQ控制台中,除了本文介绍的,其它功能可能只供 MQ 使用,Kafka 暂时用不了。Kafka 自有控制台正在开发中,敬请期待。
查询消息
您可以根据Topic来查询具体的消息,步骤如下:
- 在MQ控制台点击[backcolor=transparent]消息查询-[backcolor=transparent]Topic查询。
- 在搜索框中输入 topic 名称, 然后点击[backcolor=transparent]搜索。
- 在消息搜索结果的列表中,点击相应消息的[backcolor=transparent]消息详情按钮,查看该消息的详细信息。
目前有用的信息是四个:消费TPS,堆积总量,最近消费时间,消费延迟时间;其它信息(是否在线、连接状态等)暂时对Kafka无用。
- [backcolor=transparent]*[backcolor=transparent] [backcolor=transparent]消费[backcolor=transparent]TPS[backcolor=transparent]:消费的速度
- [backcolor=transparent]*[backcolor=transparent] [backcolor=transparent]堆积总量:消息的总条数[backcolor=transparent] [backcolor=transparent]-[backcolor=transparent] [backcolor=transparent]已经消费的消息条数
- [backcolor=transparent]*[backcolor=transparent] [backcolor=transparent]最近消费时间:取最近消费的消息,取出它的存储时间;在所有分区中取最近;
- [backcolor=transparent]*[backcolor=transparent] [backcolor=transparent]消费延迟时间:取最近消费的消息,取出它的存储时间,用当前时间减去这个时间;在所有分区中取延迟最大的;[backcolor=transparent]
堆积总量是一个关键指标,其它指标是一个估计值,仅供参考。如果发现堆积总量较大,则应用消费端可能产生了阻塞或者是消费速度跟不上生产速度,此时需要分析消费端的运行状况,尽力提升消费速度。
[backcolor=transparent]注意:目前只支持显示堆积总量,后续您会看到各个分区的堆积量,敬请期待。堆积报警暂时不适用于 Kafka,功能开发中,敬请期待。