操作场景
您可以查看指定Topic不同分区的偏移量、消息大小、创建时间以及消息正文。
操作步骤
步骤 1 登录管理控制台。
步骤 2 在管理控制台右上角单击,选择区域。
说明请选择Kafka实例所在的区域。
步骤 3 在管理控制台左上角单击,选择“企业中间件”-“分布式消息服务”-“Kafka专享版”,进入分布式消息服务Kafka专享版页面。
步骤 4 单击Kafka实例名称,进入实例详情页面。
步骤 5 选择“消息查询”页签,在消息页签页面,设置查询的Topic名称、分区以及查询方式。
如果未设置具体分区,查询结果显示Topic所有分区的消息。
查询方式支持以下两种方式:
- 按创建时间查询:即按生产该消息的时间。
- 按偏移量查询:即记录消息的位置。
说明当Topic中的数据量比较大时,单副本Topic查询消息可能会报“内部服务错误”,建议根据数据量适当减小查询时间范围。
步骤 6 单击“搜索”,查询消息。
查询结果如下:
图 查询Topic消息
消息的参数说明如下:
- Topic名称:消息所在的Topic名称。
- 分区:消息所在的分区。
- 偏移量:消息在分区中的位置。
- 消息大小:消息存入磁盘的大小,单位为B。
- 创建时间:消息的创建时间。创建时间由生产客户端在生产消息时通过CreateTime指定的,如果生产消息时没有设置此参数,创建时间会默认为1970。
步骤 7 单击“查看消息正文”,弹出“查看消息正文”对话框,查看消息的内容,包括Topic名称、分区、偏移量、创建时间和消息正文。
步骤 8 (可选)如果需要恢复默认设置,单击“重置”。