From 1c5ca1c7556946a7d06e9b733816a43c747989f0 Mon Sep 17 00:00:00 2001 From: also Date: Fri, 20 Sep 2019 17:07:58 +0800 Subject: [PATCH] Fix: skip compressing if message is a batch one --- src/producer/DefaultMQProducer.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/producer/DefaultMQProducer.cpp b/src/producer/DefaultMQProducer.cpp index 20ba96800..557f52980 100644 --- a/src/producer/DefaultMQProducer.cpp +++ b/src/producer/DefaultMQProducer.cpp @@ -397,12 +397,13 @@ SendResult DefaultMQProducer::sendKernelImpl(MQMessage& msg, 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());