更新时间:2024-07-18 GMT+08:00

查看Kafka消息

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

查看Kafka消息

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

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

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

    表1 查询消息参数说明

    参数名称

    说明

    Topic名称

    选择待查询消息的Topic名称。

    分区

    选择消息所在的分区。

    如果未设置具体分区,查询结果显示Topic所有分区的消息。

    查询方式

    查询方式支持以下两种方式:

    • 按创建时间查询:即按生产该消息的时间。
    • 按偏移量查询:即记录消息的位置。

    查询内容

    仅在“查询方式”为“按创建时间查询”时,存在此参数。

    输入消息正文的关键字。

    说明:

    由于查询资源和性能限制,使用关键字查询消息时,最大搜索范围为10000条消息且所有消息的总大小不超过200MB,最多返回符合关键字的前10条消息。查询超大消息(即单条消息超过20KB)或时间跨度大的消息时,建议将消息下载到本地,在本地进行关键字查询。

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

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

    查询结果如下:

    图1 查询Topic消息

    消息的参数说明如下:

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

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

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

  9. (可选)如果需要恢复默认设置,单击“重置”。