查询消息

最近更新时间:2024-09-04 11:59:01

我的收藏

操作场景

若您遇到消息消费异常,可以在 CKafka 控制台查询异常消息来排查问题。该任务指导您通过 CKafka 控制台查询消息。
CKafka 控制台支持按位点查询和按时间查询两种方式查询消息,适用场景如下:
按位点查询:用户能明确知道消息发送至 Topic 的分区 ID 以及消息位点。
按时间查询:用户不确定消息的位置,但确定消息发送的时间。
注意
单次查询最多查询起始时间或者起始位点之后的20条消息,并不会列出所有消息。
查询消息也会消耗一定的带宽资源,切勿频繁操作。
目前消息查询仅支持查询 1 MB 内的消息。

操作步骤

按位点查询

1. 登录 CKafka 控制台
2. 在左侧导航栏选择实例列表,选择地域后,单击目标实例的“ID/名称”,进入实例详情页。
3. 在实例详情页,选择 topic 管理,单击目标 Topic 右侧操作列的更多 > 消息查询
4. 在消息查询页面,选择按位点查询,选择需要查询的分区 ID 和起始位点,单击查询,查看消息信息。

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


按时间查询

1. 登录 CKafka 控制台
2. 在左侧导航栏选择实例列表,选择地域后,单击目标实例的“ID/名称”,进入实例详情页。
3. 在实例详情页,选择 topic 管理,单击目标 Topic 右侧操作列的更多 > 消息查询
4. 在消息查询页面,选择按起始时间查询,选择需要查询的分区 ID 和时间,单击查询,查看消息信息。

分区 ID:消息的 Topic 分区。
位点:消息的消费位点。
时间戳:为 ProducerRecord 中的 timestamp
操作:
单击下载消息可以下载消息,包含消息的 Headers,Key,Value。支持批量下载消息。
单击查看详情可查看消息详情。