You need to enable JavaScript to run this app.
文档中心
消息队列 Kafka版

消息队列 Kafka版

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