RocketMq查看消息轨迹

发布时间：2023年12月18日

查看消息轨迹

1.修改配置文件
broker的启动文件加上消息轨迹相关配置

##if msg tracing is open,the flag will be true
traceTopicEnable=true

2.启动broker
使用broker-a.properties配置文件后台启动Broker。

nohup mqbroker -c /usr/local/rocketmq/rocketmq-all-4.9.1-bin-release/conf/2m-2s-async/broker-a.properties &

3.rocketmq-client代码改动如下

  1. 发送消息时开启消息轨迹
    enableMsgTrace增加一个开关参数(enableMsgTrace)来实现消息轨迹是否开启；
    customizedTraceTopic新增一个自定义参数(customizedTraceTopic)来实现用户存储消息轨迹数据至自己创建的用户级Topic
DefaultMQProducer producer = new DefaultMQProducer("Producer",true,"gj"); //（1）
  1. 订阅消息时开启消息轨迹
    enableMsgTrace增加一个开关参数(enableMsgTrace)来实现消息轨迹是否开启；
    customizedTraceTopic新增一个自定义参数(customizedTraceTopic)来实现用户存储消息轨迹数据至自己创建的用户级Topic
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("Consumer",true,"gj");

4.控制台查看消息轨迹
在这里插入图片描述
在这里插入图片描述

文章来源:https://blog.csdn.net/qq_37200262/article/details/135066299
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
最新文章