diff --git a/example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingTransactionProducer.java b/example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingTransactionProducer.java index 428640a383b6149093965155ab5638515794acbc..514f3ceb7fe6fe0f3491de05f64485072118df37 100644 --- a/example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingTransactionProducer.java +++ b/example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingTransactionProducer.java @@ -57,7 +57,7 @@ public class OpenTracingTransactionProducer { try { Message msg = new Message("TopicTest", "Tag", "KEY", - ("Hello RocketMQ").getBytes(RemotingHelper.DEFAULT_CHARSET)); + "Hello RocketMQ".getBytes(RemotingHelper.DEFAULT_CHARSET)); SendResult sendResult = producer.sendMessageInTransaction(msg, null); System.out.printf("%s%n", sendResult); } catch (MQClientException | UnsupportedEncodingException e) {