RocketMq查看消息轨迹_rocketmq中如何查看消息确认的时间?

查看消息轨迹

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

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

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 & 
1

3.rocketmq-client代码改动如下

1. 发送消息时开启消息轨迹
   enableMsgTrace增加一个开关参数(enableMsgTrace)来实现消息轨迹是否开启；
   customizedTraceTopic新增一个自定义参数(customizedTraceTopic)来实现用户存储消息轨迹数据至自己创建的用户级Topic

DefaultMQProducer producer = new DefaultMQProducer("Producer",true,"gj"); //（1）
1

2. 订阅消息时开启消息轨迹
   enableMsgTrace增加一个开关参数(enableMsgTrace)来实现消息轨迹是否开启；
   customizedTraceTopic新增一个自定义参数(customizedTraceTopic)来实现用户存储消息轨迹数据至自己创建的用户级Topic

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("Consumer",true,"gj");
1

4.控制台查看消息轨迹