出现消息堆积的警告

Recent Pages

出现消息堆积的警告

最后更新时间：2024-01-09 14:57:56

问题概述
出现消息堆积的警告。
可能原因
客户端没有消费。
客户端消费速度较慢。
解决方法
客户端没有消费，可以通过查看分区的消费速度来确认，是否有进行消费，如下图：
﻿
﻿
﻿
客户端消费速度较慢，请参见 消费端消费消息速度缓慢。
推荐设置
开源 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 进行生产和消费压力测试。

联系我们

联系我们，为您的业务提供专属服务。

技术支持

如果你想寻求进一步的帮助，通过工单与我们进行联络。我们提供7x24的工单服务。

7x24 电话支持

tencent cloud

Recent Pages

出现消息堆积的警告

问题概述

可能原因

解决方法

推荐设置

压测服务端性能

本页内容是否解决了您的问题？

本页内容是否解决了您的问题？

tencent cloud

注册

登录

Recent Pages

出现消息堆积的警告

问题概述

可能原因

解决方法

推荐设置

压测服务端性能

本页内容是否解决了您的问题？

本页内容是否解决了您的问题？