产品文档

消息队列 Kafka 版

可根据具体情况按以下推荐方式查询消息:

  • 知道消息所在Topic的分区ID以及分区信息和消息位点,则推荐您使用按位点查询消息。位点的相关概念,请参见名词解释。
  • 如果确定消息发送的时间,则推荐您使用按时间查询消息。

按位点查询消息

确定消息的位点,则可以按照消息的分区位点进行查询

  1. 登录消息队列Kafka版控制台。
  2. 在概览页面的资源分布区域,选择地域。
  3. 在实例列表页面,单击目标实例名称。
  4. 在导航栏,单击消息查询。
  5. 在消息查询页面的查询方式列表中,选择按位点查询。
  6. 在Topic列表中,选择消息所属Topic名称;在分区列表中,选择消息所属的分区;在起始位点文本框,输入消息所在分区的位点,然后单击查询。 按照位点查询 表 1. 查询结果参数解释
参数 说明
分区 消息的Topic分区。
位点 消息的所在的位点。
消息大小 查询消息的大小。
消息创建时间 发送消息时,客户端自带的或是您指定的ProducerRecord中的消息创建时间。
操作 点击查看消息内容,可看到消息的具体内容,被消费时间

按时间查询消息

按时间查询,不确定消息的位置,但确定消息发送的时间段,请指定该时间段中的某一个时间段查询该时间段附近的消息。

  1. 登录消息队列Kafka版控制台。
  2. 在概览页面的资源分布区域,选择地域。
  3. 在实例列表页面,单击目标实例名称。
  4. 导航栏,单击消息查询。
  5. 在消息查询页面的查询方式列表中,选择按时间查询。
  6. 在Topic列表中,选择消息所属Topic名称;在分区列表中,选择消息所属的分区;在时间筛选中,选择需查询的时间段,然后单击查询。

按照位点查询 展示该查询时间点及之后连续的消息。查询结果的参数,请参见表 1。

更新时间:2022-11-03 10:35:32
feedback