From 7496081da676f4d2cb8f9c2a256a3aa692cdf2bf Mon Sep 17 00:00:00 2001
From: Kvicii <42023367+Kvicii@users.noreply.github.com>
Date: Sat, 5 Feb 2022 16:56:14 +0800
Subject: [PATCH] fix ISSUE 2812 (#3813)

---
 .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index b6e99ba0e3..9afbe9bcb7 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -732,7 +732,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
                 }
 
                 final String tranMsg = msg.getProperty(MessageConst.PROPERTY_TRANSACTION_PREPARED);
-                if (tranMsg != null && Boolean.parseBoolean(tranMsg)) {
+                if (Boolean.parseBoolean(tranMsg)) {
                     sysFlag |= MessageSysFlag.TRANSACTION_PREPARED_TYPE;
                 }