分布式消息服务ROCKETMQ版-开启和查询RocketMQ消息轨迹:开启RocketMQ消息轨迹(Java)

时间:2024-10-17 19:27:15

开启RocketMQ消息轨迹(Java)

在客户端开启消息轨迹的方法如下:

  • 生产者开启消息轨迹(除事务消息以外的消息类型

    构造函数的“enableMsgTrace”参数传入“true”,例如:

    DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName", true);
  • 生产者开启消息轨迹(事务消息

    构造函数的“enableMsgTrace”参数传入“true”,例如:

    TransactionMQProducer producer = new TransactionMQProducer(null, "ProducerGroupName", null, true, null);
  • 消费者开启消息轨迹

    构造函数的“enableMsgTrace”参数传入“true”,例如:

    DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroupName", true);
support.huaweicloud.com/usermanual-hrm/hrm-ug-028.html