commit 0420f8920b887ff8f7e4e361314bded601a3aa73
author also <wuzhyy@163.com> Fri Sep 20 17:07:58 2019 +0800
committer dinglei <libya_003@163.com> Thu Sep 26 15:53:39 2019 +0800
tree caaab7982b824d652770cd645f1af75321e6658a
parent 2dfbb0cef78e60298b8c26185a34125b12ae0bf4

Fix: skip compressing if message is a batch one

src/producer/DefaultMQProducer.cpp

diff --git a/src/producer/DefaultMQProducer.cpp b/src/producer/DefaultMQProducer.cpp
index 20ba968..557f529 100644
--- a/src/producer/DefaultMQProducer.cpp
+++ b/src/producer/DefaultMQProducer.cpp
@@ -397,12 +397,13 @@
       if (!isBatchMsg) {
         string unique_id = StringIdMaker::get_mutable_instance().get_unique_id();
         msg.setProperty(MQMessage::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX, unique_id);
+
+        // batch does not support compressing right now,
+        tryToCompressMessage(msg);
       }
 
       LOG_DEBUG("produce before:%s to %s", msg.toString().c_str(), mq.toString().c_str());
 
-      tryToCompressMessage(msg);
-
       SendMessageRequestHeader* requestHeader = new SendMessageRequestHeader();
       requestHeader->producerGroup = getGroupName();
       requestHeader->topic = (msg.getTopic());