opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix outdated constructor signatures in trace documentation (#10501)

Browse Source 
The two-argument constructors DefaultMQProducer(String, boolean) and
DefaultMQPushConsumer(String, boolean) do not exist in 5.x.
Updated to use the three-argument form with null for the default
trace topic.

Fixes #10500
This commit is contained in:
KaiQuan Chen
2026-06-15 20:25:30 +08:00
committed by GitHub
parent 4082e31d88
commit 226e24faf6
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
docs/cn/msg_trace/user_guide.md
+2 -2
View File
@@ -54,7 +54,7 @@ RocketMQ的消息轨迹特性支持两种存储轨迹数据的方式：
### 4.1 发送消息时开启消息轨迹
```java
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName",true);
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName",true,null);
producer.setNamesrvAddr("XX.XX.XX.XX1");
producer.start();
try {
@@ -74,7 +74,7 @@ RocketMQ的消息轨迹特性支持两种存储轨迹数据的方式：
### 4.2 订阅消息时开启消息轨迹
```java
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_JODIE_1",true);
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_JODIE_1",true,null);
consumer.subscribe("TopicTest", "*");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.setConsumeTimestamp("20181109221800");
docs/en/msg_trace/user_guide.md
+2 -2
View File
@@ -54,7 +54,7 @@ For business system adapting to use RocketMQ's message trace feature easily, in
### 4.1 Enable message trace when sending messages
```
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName",true);
DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName",true,null);
producer.setNamesrvAddr("XX.XX.XX.XX1");
producer.start();
try {
@@ -74,7 +74,7 @@ For business system adapting to use RocketMQ's message trace feature easily, in
### 4.2 Enable message trace when subscribe messages
```
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_JODIE_1",true);
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_JODIE_1",true,null);
consumer.subscribe("TopicTest", "*");
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.setConsumeTimestamp("20181109221800");