Tencent Cloud

Recent Pages

查询消息

最后更新时间：2024-11-07 15:35:58

操作场景
若您遇到消息消费异常，可以在 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。支持批量下载消息。
单击查看详情可查看消息详情。
﻿
﻿