消息查询
最近更新时间：2023.03.31 11:46:32
首次发布时间：2022.03.02 10:30:01
成功接入消息队列 Kafka版之后，如果遇到消息消费异常，可以通过消息查询功能查看服务端的详细消息内容，确认服务端的消息详情是否与生产端或消费端完全一致，排查消息生产或消费问题。
背景信息
消息队列 Kafka版提供以下方式查询消息详情。
- 按位点查询。查询指定 Topic 中、指定分区、指定位点对应的消息，适用于消息发送至的分区 ID 及消息位点非常明确的场景。
- 按时间查询。查询指定 Topic、指定分区或所有分区在指定时间范围内的消息列表。按时间范围查询时，会筛选出符合条件的消息列表，适用于消息发送的时间段非常明确的场景。
推荐您在以下场景中使用消息查询功能：
- 查看消息的具体内容，验证消息内容是否和生产端/消费端一致。
- 下载指定消息内容，以供进一步的问题排查。
注意事项
- 消息在消息队列 Kafka版中的存储时间由参数消息保留时长决定，超过存储时长的消息将会被系统定时删除，查看过程中，可能会存在消息过期删除的情况。 您可以通过修改参数消息保留时长配置调整消息的过期删除策略。详细信息请参考修改参数配置。
- 存储空间不足时，后台会删除历史消息，可能有部分消息已被删除无法查询。
- 针对每次查询，页面最多展示 16 条查询结果，且消息内容的总大小不超过 10MiB。如果单条消息体较大，例如 10 条消息内容的总大小未超限，11 条时将超限，则仅返回前 10 条结果。您可以单击点击加载更多，查看更多结果。数据量较大时，建议缩小时间范围、分批次查询。
- 查询到的每条消息在控制台上最多显示 1KiB 的内容，超过 1KiB 的部分将自动截断。如需查看完整的消息内容，请下载消息，并在 Base64 解码后查看。
前提条件
已经部署生产端服务、成功接入消息队列 Kafka版。
按位点查询消息
在顶部菜单栏中选择地域，并在选择左侧导航栏中单击实例列表。
找到目标实例，单击实例名称。
在顶部页签栏中单击消息查询。
选择按位点查询，并指定目标消息所在的 Topic、分区及起始位点。
说明
设置 Topic 和分区之后，页面会提示起始位点的可选范围，您需要设置指定范围内的起始位点，可选范围外的位点无消息可被查询。
单击查询。
页面展示符合筛选条件的消息列表，其中包括 Topic 名称、分区、位点、Key、Value、消息大小和存储时间。展示项
说明
Topic名称
消息发送至的 Topic。
分区
消息对应的 Topic 分区。
位点
消息所在的位点。
Key
消息的 Key。发送消息时若未设置 Key，则此处显示为 -。页面展示时会将 Key 强制转化为 String 类型。
Value
消息体，即消息的具体内容。为便于查看，页面展示时会将消息内容强制转化为 String 类型。
说明
查询到的每条消息在控制台上最多显示 1KiB 的内容，超过 1KiB 的部分将自动截断。如需查看完整的消息内容，请下载消息后解码查看。
Value 消息大小（Value）
此条消息体的长度，单位为字节（Byte）。
存储时间
消息存储的时间，即
ProducerRecord中的timestamp。
按时间查询消息
在顶部菜单栏中选择地域，并在选择左侧导航栏中单击实例列表。
找到目标实例，单击实例名称。
在顶部页签栏中单击消息查询。
选择按时间查询，并设置目标消息所在的 Topic、分区及消息存储的时间范围。
单击查询。
页面展示符合筛选条件的消息列表，其中包括 Topic 名称、分区、位点、Key、Value、消息大小和存储时间。展示项
说明
Topic名称
消息发送至的 Topic。
分区
消息对应的 Topic 分区。支持设置为全部，表示在所有分区中查询消息。
位点
消息所在的位点。
Key
消息的 Key。发送消息时若未设置 Key，则此处显示为 -。已强制转化为 String 类型。
Value
消息体，即消息的具体内容。已强制转化为 String 类型。
说明
查询到的每条消息在控制台上最多显示 1KiB 的内容，超过 1KiB 的部分将自动截断。如需查看完整的消息内容，请下载消息后解码查看。
Value 消息大小（Value）
此条消息体的长度，单位为字节（Byte）。
存储时间
消息存储的时间，即
ProducerRecord中的timestamp。
下载消息
查找到指定的消息后，可以在消息查询页签中下载消息的具体内容，与生产端或消费端的消息内容进行比对，排查生产消费环节的问题。
- 按位点或按时间查询消息。
- 在查询结果中，找到指定的消息，并在其操作列中单击下载消息。
页面自动下载.txt格式的消息文件，通过 Base64 编码传输。开发者拿到文件之后，需要解码后才能查看实际消息内容。