查看Kafka消息

约束与限制

• 当Topic中的数据量比较大时，单副本Topic查询消息可能会报“内部服务错误”，建议根据数据量适当减小查询时间范围。
• 使用关键字查询消息时，由于查询资源和性能限制，最大搜索范围为10000条消息且所有消息的总大小不超过200MB，最多返回符合关键字的前10条消息。
• 控制台只能展示4KB以内的消息，超过4KB的消息，请单击“下载消息”，下载到本地查看消息完整的内容。

查看Kafka消息

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

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

3. 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
4. 在左侧导航栏单击“Kafka实例”，进入Kafka实例列表页面。
5. 单击Kafka实例名称，进入实例详情页面。
6. 在左侧导航栏选择“消息查询”，进入消息列表页面。
7. Kafka实例支持两种查询消息的方法：按创建时间查询和按偏移量查询，具体查询参数参见表1和表2。

   表1 按创建时间查询消息

   参数名称	说明
   Topic名称	选择待查询消息的Topic名称。
   分区	输入消息所在的分区。 如果未设置具体分区，查询结果显示Topic所有分区的消息。
   查询内容	输入消息正文的关键字。 说明： 由于查询资源和性能限制，使用关键字查询消息时，最大搜索范围为10000条消息且所有消息的总大小不超过200MB，最多返回符合关键字的前10条消息。查询超大消息（即单条消息超过20KB）或时间跨度大的消息时，建议将消息下载到本地，在本地进行关键字查询。
   创建时间	设置待查询消息的时间范围。 说明： 当Topic中的数据量比较大时，单副本Topic查询消息可能会报“内部服务错误”，建议根据数据量适当减小查询时间范围。

   表2 按偏移量查询消息

   参数名称	说明
   Topic名称	选择待查询消息的Topic名称。
   分区	输入消息所在的分区。
   偏移量	输入消息的偏移量。

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

   查询结果如下：

   图1 查询Topic消息
   

   消息的参数说明如下：

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

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

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

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