查询消息

最近更新时间:2025-08-15 15:03:02

我的收藏

操作场景

若您遇到消息生产消费异常,例如消息丢失或消息消费失败等问题,可以在 CKafka 控制台查询异常消息来排查问题。CKafka 支持按位点查询和按时间查询两种方式查询消息,适用场景如下:
按位点查询:用户能明确知道消息发送至 Topic 的分区 ID 以及消息位点。
按时间查询:用户不确定消息的位置,但确定消息发送的时间。

约束与限制

单次查询最多展示起始时间或者起始位点之后的 20 条消息(如起始时间或者起始位点后消息不足 20 条则会全量展示)。
查询消息也会消耗一定的带宽资源,切勿频繁操作。
目前消息查询仅支持查询 1 MB 以内的消息。
能否查询到消息与消息保留机制相关,用户可以配置消息在被删除之前可以保留多长时间或占用多大空间,同时 CKafka 支持配置动态消息保留时间。

操作步骤

1. 登录 CKafka 控制台
2. 在左侧导航栏选择消息查询,选择好地域后,在消息查询页面,设置查询条件。
实例:在下拉框中选择要查看的实例。
Topic:在下拉框中选择要消息所在的 Topic。
查询类型:支持按位点查询按时间查询两种方式。
分区 ID:选择消息所在的分区。
起始位点:查询类型为按位点查询时,需输入消息的起始位点。
时间:查询类型为按时间查询时,需设置查询的起始时间,精确到秒。
3. 单击查询,查看消息信息。

分区 ID:消息的 Topic 分区。
位点:消息的消费位点。
时间戳:为 ProducerRecord 中的 timestamp
操作:
单击下载消息可以下载消息,格式为 header,key,value。支持批量下载消息。
单击消息详情可查看消息的 key 和 value。