分布式消息服务Kafka版-为什么Console页面上,消息查询查不到消息?

时间:2023-11-01 16:23:06

为什么Console页面上,消息查询查不到消息?

  • 可能原因1:消息已被老化。

    解决方法:修改老化时间。

  • 可能原因2:消息的createTime时间戳不对。

    Console页面是根据时间查询的,所以查不到。时间戳是由客户端生成,不同客户端有不同的处理策略,有的客户端默认值会是0或者-1,则查询不到消息。

    解决方法:检查客户端消息的createTime设置是否正确。

  • 可能原因3:磁盘容量超过95%,且“容量阈值策略”设置为“自动删除”。

    “容量阈值策略”设置为“自动删除”,表示磁盘容量达到95%时,系统会删除最早的10%的消息,以保证磁盘容量充足。当磁盘容量超过95%时,未到达老化时间的消息也会被删除,所以可能会导致部分消息查询不到。

    解决方法:修改容量阈值策略或扩大磁盘容量。“容量阈值策略”设置为“生产受限”,表示一旦磁盘使用达到容量阈值95%,会导致后续生产失败,但保留了当前磁盘中的数据,直至数据自然老化。该场景适用于对数据不能丢的业务场景,但是会导致生产业务失败。

support.huaweicloud.com/kafka_faq/kafka-faq-200426037.html