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

- 分区 ID:消息的 Topic 分区。
- 位点:消息的消费位点。
- 时间戳:为
ProducerRecord中的timestamp。 - 操作:单击消息详情可查看消息的 key 和 value。


