成功接入消息队列 Kafka版之后,如果遇到消息消费异常,可以通过消息查询功能查看服务端的详细消息内容,确认服务端的消息详情是否与生产端或消费端完全一致,排查消息生产或消费问题。
消息队列 Kafka版提供以下方式查询消息详情。
推荐您在以下场景中使用消息查询功能:
已经部署生产端服务、成功接入消息队列 Kafka版。
在顶部菜单栏中选择地域,并在选择左侧导航栏中单击实例列表。
找到目标实例,单击实例名称。
在顶部页签栏中单击消息查询。
选择按位点查询,并指定目标消息所在的 Topic、分区及起始位点。
说明
设置 Topic 和分区之后,页面会提示起始位点的可选范围,您需要设置指定范围内的起始位点,可选范围外的位点无消息可被查询。
单击查询。
页面展示符合筛选条件的消息列表,其中包括 Topic 名称、分区、位点、Key、Value、消息大小和存储时间。
展示项 | 说明 |
---|---|
Topic名称 | 消息发送至的 Topic。 |
分区 | 消息对应的 Topic 分区。 |
位点 | 消息所在的位点。 |
Key | 消息的 Key。发送消息时若未设置 Key,则此处显示为 -。页面展示时会将 Key 强制转化为 String 类型。 |
Value | 消息体,即消息的具体内容。为便于查看,页面展示时会将消息内容强制转化为 String 类型。 说明 查询到的每条消息在控制台上最多显示 1KiB 的内容,超过 1KiB 的部分将自动截断。如需查看完整的消息内容,请下载消息后解码查看。 |
Value 消息大小(Value) | 此条消息体的长度,单位为字节(Byte)。 |
存储时间 | 消息存储的时间,即 |
在顶部菜单栏中选择地域,并在选择左侧导航栏中单击实例列表。
找到目标实例,单击实例名称。
在顶部页签栏中单击消息查询。
选择按时间查询,并设置目标消息所在的 Topic、分区及消息存储的时间范围。
说明
支持预设时间和自定义时间两种方式。为了方便查询消息,已提前预制了多种时间段。
单击查询。
页面展示符合筛选条件的消息列表,其中包括 Topic 名称、分区、位点、Key、Value、消息大小和存储时间。
展示项 | 说明 |
---|---|
Topic名称 | 消息发送至的 Topic。 |
分区 | 消息对应的 Topic 分区。支持设置为全部,表示在所有分区中查询消息。 |
位点 | 消息所在的位点。 |
Key | 消息的 Key。发送消息时若未设置 Key,则此处显示为 -。已强制转化为 String 类型。 |
Value | 消息体,即消息的具体内容。已强制转化为 String 类型。 说明 查询到的每条消息在控制台上最多显示 1KiB 的内容,超过 1KiB 的部分将自动截断。如需查看完整的消息内容,请下载消息后解码查看。 |
Value 消息大小(Value) | 此条消息体的长度,单位为字节(Byte)。 |
存储时间 | 消息存储的时间,即 |
查找到指定的消息后,可以在消息查询页签中下载消息的具体内容,与生产端或消费端的消息内容进行比对,排查生产消费环节的问题。
说明
暂不支持批量下载消息。
.txt
格式的消息文件,文件中展示完整的消息内容。