新功能发布记录
Broker 版本升级记录
公告
查询消息
操作场景
若您遇到消息生产消费异常，例如消息丢失或消息消费失败等问题，可以在 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。
文档反馈