tencent cloud

文档反馈

出现消息堆积的警告

最后更新时间:2024-05-31 14:20:36

    问题概述

    出现消息堆积的警告。

    可能原因

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

    解决方法

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

    推荐设置

    开源 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
    联系我们

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

    技术支持

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

    7x24 电话支持