成功接入消息队列 Kafka版之后，如果遇到消息消费异常，可以通过消息查询功能查看服务端的详细消息内容，确认服务端的消息详情是否与生产端或消费端完全一致，排查消息生产或消费问题。 ## 背景信息消息队列 Kafka版提供以下方式查询消息详情。 * 按位点查询。查询指定 Topic 中、指定分区、指定位点对应的消息，适用于消息发送至的分区 ID 及消息位点非常明确的场景。 * 按时间查询。查询指定 Topic、指定分区或所有分区在指定时间范围内的消息列表。按时间范围查询时，会筛选出符合条件的消息列表，适用于消息发送的时间段非常明确的场景。推荐您在以下场景中使用消息查询功能： * 查看消息的具体内容，验证消息内容是否和生产端/消费端一致。 * 下载指定消息内容，以供进一步的问题排查。 ## 注意事项 * 消息在消息队列 Kafka版中的存储时间由参数**消息保留时长**决定，超过存储时长的消息将会被系统定时删除，查看过程中，可能会存在消息过期删除的情况。您可以通过修改参数**消息保留时长**配置调整消息的过期删除策略。详细信息请参考[修改参数配置](https://www.volcengine.com/docs/6439/102156)。 * 存储空间不足时，后台会删除历史消息，可能有部分消息已被删除无法查询。 * 针对每次查询，页面最多展示 16 条查询结果，且消息内容的总大小不超过 10MiB。例如 10 条消息内容的总大小未超限，如果第 11 条消息体较大导致总大小超限，则仅返回前 10 条结果。您可以单击**点击加载更多**，查看更多结果。数据量较大时，建议缩小时间范围、分批次查询。 * 查询到的每条消息在控制台上最多显示 1KiB 的内容，超过 1KiB 的部分将自动截断。如需查看完整的消息内容，请下载消息到本地后查看。 ## 前提条件已经部署生产端服务、成功接入消息队列 Kafka版。 ## 按位点查询消息 1. 登录[消息队列 Kafka版控制台](https://console.volcengine.com/kafka)。 2. 在顶部菜单栏中选择实例所在的地域。 3. 在**实例列表**页面单击指定实例名称。 4. 在顶部页签栏中单击**消息查询**。 5. 选择**按位点查询**，并指定目标消息所在的 **Topic**、**分区**及**起始位点**。 :::tip 设置 **Topic** 和分区之后，页面会提示起始位点的可选范围，您需要设置指定范围内的起始位点，可选范围外的位点无消息可被查询。 ![图片](https://p9-arcosite.byteimg.com/tos-cn-i-goo7wpa0wc/cbe8b49efa6748ea8d8613e6ae47fb43~tplv-goo7wpa0wc-image.image =632x) ::: 6. 单击**查询**。页面展示符合筛选条件的消息列表，其中包括 Topic 名称、分区、位点、Key、Value、消息大小和存储时间。 |**展示项** |**说明** | |---|---| |Topic名称 |消息发送至的 Topic。 | |分区 |消息对应的 Topic 分区。 | |位点 |消息所在的位点。 | |Key |消息的 Key。发送消息时若未设置 Key，则此处显示为 \-。页面展示时会将 Key 强制转化为 String 类型。 | |Value |消息体，即消息的具体内容。为便于查看，页面展示时会将消息内容强制转化为 String 类型。|\ | |:::tip|\ | |查询到的每条消息在控制台上最多显示 1KiB 的内容，超过 1KiB 的部分将自动截断。如需查看完整的消息内容，请下载消息后解码查看。|\ | ||\ | |:::| |Value 消息大小 |此条消息体的长度，单位为字节（Byte）。 | |存储时间 |消息存储的时间，即 `ProducerRecord` 中的 `timestamp`。 | ## 按时间查询消息 1. 登录[消息队列 Kafka版控制台](https://console.volcengine.com/kafka)。 2. 在顶部菜单栏中选择实例所在的地域。 3. 在**实例列表**页面单击指定实例名称。 4. 在顶部页签栏中单击**消息查询**。 5. 选择**按时间查询**，并设置目标消息所在的 Topic、分区及消息存储的时间范围。 :::tip 支持**预设时间**和**自定义时间**两种方式。为了方便查询消息，已提前预制了多种时间段。 ::: 6. 单击**查询**。页面展示符合筛选条件的消息列表，其中包括 Topic 名称、分区、位点、Key、Value、消息大小和存储时间。 |**展示项** |**说明** | |---|---| |Topic名称 |消息发送至的 Topic。 | |分区 |消息对应的 Topic 分区。支持设置为**全部**，表示在所有分区中查询消息。 | |位点 |消息所在的位点。 | |Key |消息的 Key。发送消息时若未设置 Key，则此处显示为 \-。已强制转化为 String 类型。 | |Value |消息体，即消息的具体内容。已强制转化为 String 类型。|\ | |:::tip|\ | |查询到的每条消息在控制台上最多显示 1KiB 的内容，超过 1KiB 的部分将自动截断。如需查看完整的消息内容，请下载消息后解码查看。|\ | ||\ | |:::| |Value 消息大小 |此条消息体的长度，单位为字节（Byte）。 | |存储时间 |消息存储的时间，即 `ProducerRecord` 中的 `timestamp`。 | ## 下载消息查找到指定的消息后，可以在消息查询页签中下载消息的具体内容，与生产端或消费端的消息内容进行比对，排查生产消费环节的问题。 :::tip 暂不支持批量下载消息。 ::: 1. 按位点或按时间查询消息。 2. 在查询结果中，找到指定的消息，并在其**操作**列单击**下载消息**。页面自动下载 `.txt`格式的消息文件，文件中展示完整的消息内容。 ![图片](https://p9-arcosite.byteimg.com/tos-cn-i-goo7wpa0wc/55abf2a24acc4e7098cbf01f3af172cd~tplv-goo7wpa0wc-image.image =676x)