消息查询

最近更新时间: 2026-03-13 09:03:00

操作场景

若您遇到消息消费异常,可以在 CKafka 控制台查询异常消息来排查问题。该任务指导您通过 CKafka 控制台查询消息。
CKafka 控制台支持按位点查询和按时间查询两种方式查询消息,适用场景如下:

  • 按位点查询:用户能明确知道消息发送至 Topic 的分区 ID 以及消息位点。
  • 按时间查询:用户不确定消息的位置,但确定消息发送的时间。

    注意

    • 单次查询最多查询起始时间或者起始位点之后的20条消息,并不会列出所有消息。
    • 查询消息也会消耗一定的带宽资源,切勿频繁操作。
    • 目前消息查询仅支持查询 1 MB 内的消息。

操作步骤

  1. 登录 CKafka 控制台,在左侧导航栏选择消息查询
  2. 在消息查询页面,选择要需要查询的实例和 Topic,以及查询方式,单击查询,查看消息信息。
    • 分区 ID:消息的 Topic 分区。
    • 位点:消息的消费位点。
    • 时间戳:为 ProducerRecord 中的 timestamp
    • 操作:单击消息详情可查看消息的 key 和 value。