查询消息

操作场景

您可以查看指定Topic不同分区的偏移量、消息大小、创建时间以及消息正文。

操作步骤

1. 登录管理控制台。
2. 在管理控制台左上角单击，选择区域。
   

   请选择Kafka实例所在的区域。

3. 在管理控制台左上角单击，选择“应用服务 > 分布式消息服务 Kafka”，进入分布式消息服务Kafka专享版页面。
4. 单击Kafka实例名称，进入实例详情页面。
5. 在左侧导航栏选择“消息查询”，进入消息列表页面。
6. 参考表1，设置查询参数。

   表1 查询消息参数说明

   参数名称	说明
   Topic名称	选择待查询消息的Topic名称。
   分区	选择消息所在的分区。 如果未设置具体分区，查询结果显示Topic所有分区的消息。
   查询方式	查询方式支持以下两种方式： 按创建时间查询：即按生产该消息的时间。 按偏移量查询：即记录消息的位置。

   

   当Topic中的数据量比较大时，单副本Topic查询消息可能会报“内部服务错误”，建议根据数据量适当减小查询时间范围。

7. 单击“搜索”，查询消息。

   查询结果如下：

   图1 查询Topic消息
   

   消息的参数说明如下：

   • Topic名称：消息所在的Topic名称。
   • 分区：消息所在的分区。
   • 偏移量：消息在分区中的位置。
   • 消息大小：消息存入磁盘的大小，单位为B。
   • 创建时间：消息的创建时间。创建时间由生产客户端在生产消息时通过CreateTime指定的，如果生产消息时没有设置此参数，创建时间会默认为1970。

8. 单击“查看消息正文”，弹出“查看消息正文”对话框，查看消息的内容，包括Topic名称、分区、偏移量、创建时间和消息正文。
   

   控制台只能展示4KB以内的消息，超过4KB的消息，请单击“下载消息”，下载到本地查看消息完整的内容。

9. （可选）如果需要恢复默认设置，单击“重置”。