开发者社区 > 云原生 > 云消息队列 > 正文

RocketMQ中mqadmin 的queryMsgByOffset命令 在java对应api是哪个

在RocketMQ中有大佬知道 mqadmin 的queryMsgByOffset命令 在java对应的api是哪个吗?

展开
收起
不chi香菜 2023-08-05 12:17:23 131 0
1 条回答
写回答
取消 提交回答
  • RocketMQ 的 queryMsgByOffset 命令对应的 Java API 是 MessageClient.queryMessageById()。

    该 API 可以查询指定消息 ID 的消息。

    消息 ID 是消息的唯一标识,它由消息的主题名称、消息的队列 ID 和消息的偏移量组成。

    MessageClient.queryMessageById() 的参数如下:

    topic:消息的主题名称。
    queueId:消息的队列 ID。
    offset:消息的偏移量。
    MessageClient.queryMessageById() 返回的结果是一个 Message 对象,该对象包含了消息的所有信息。

    Message 对象的字段如下:

    body:消息的内容。
    tags:消息的标签。
    keys:消息的键。
    queueId:消息的队列 ID。
    offset:消息的偏移量。
    storeTime:消息的存储时间。

    2023-09-27 15:52:16
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
    The Reactive Cloud Native Arch 立即下载
    JAVA开发手册1.5.0 立即下载