Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions docs/cn/msg_trace/user_guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand All @@ -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");
Expand Down
4 changes: 2 additions & 2 deletions docs/en/msg_trace/user_guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand All @@ -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");
Expand Down
Loading