diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java index 9873aca89dc637c10bab7c03cf254cae6fa103c3..63b512df7d5374857624d81892acdf2c61252814 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java +++ b/client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java @@ -86,6 +86,7 @@ public class TransactionMQProducer extends DefaultMQProducer { throw new MQClientException("TransactionListener is null", null); } + msg.setTopic(NamespaceUtil.wrapNamespace(this.getNamespace(), msg.getTopic())); return this.defaultMQProducerImpl.sendMessageInTransaction(msg, null, arg); }