上云无忧 > 文档中心 > 腾讯云消息队列 CKafka - 出现消息堆积的警告
消息队列 CKafka
腾讯云消息队列 CKafka - 出现消息堆积的警告

文档简介:
问题概述: 出现消息堆积的警告。 可能原因: 客户端没有消费。 客户端消费速度较慢。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

问题概述

出现消息堆积的警告。

可能原因

客户端没有消费。
客户端消费速度较慢。

解决方法

客户端没有消费 可以通过查看分区的消费速度来确认,是否有进行消费,如下图:

客户端消费速度较慢 请参见 消费端消费消息速度缓慢

推荐设置

开源 Kafka 支持消息中设置一个时间戳字段和时间戳类型,目前支持的时间戳类型有两种: CreateTime 和 LogAppendTime。
CreateTime 表示客户端本地的时间,由于客户端的时间可能和服务器时间存在偏差,请检查写入的时间是否是正确的时间。如果时间和当前北京时间相差较远,导致 CKafka 服务无法按照正常消息保存时间对数据进行及时过期删除,因此可能会存在消息异常堆积 。
LogAppendTime 表示消息生产到 CKafka 服务的时间,时间为 CKafka 服务器的时间,建议用户选用 LogAppendTime。

压测服务端性能

如果对服务端性能有疑问,也可以执行如下压测命令来排除是否是服务端存在问题。命令如下:
生产测试命令示例:
		
bin/kafka-producer-perf-test.sh
--topic test
--num-records 123
--record-size 1000
--producer-props bootstrap.servers= ckafka vip : port
--throughput 20000
消费测试命令示例:
		
bin/kafka-consumer-perf-test.sh
--topic test
--new-consumer
--fetch-size 10000
--messages 1000
--broker-list bootstrap.servers=ckafka vip : port
详情请参见 对 CKafka 进行生产和消费压力测试
相似文档
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部