Skip to content

Commit 0420f89

Browse files
paper777ShannonDing
authored andcommitted
Fix: skip compressing if message is a batch one
1 parent 2dfbb0c commit 0420f89

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/producer/DefaultMQProducer.cpp

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -397,12 +397,13 @@ SendResult DefaultMQProducer::sendKernelImpl(MQMessage& msg,
397397
if (!isBatchMsg) {
398398
string unique_id = StringIdMaker::get_mutable_instance().get_unique_id();
399399
msg.setProperty(MQMessage::PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX, unique_id);
400+
401+
// batch does not support compressing right now,
402+
tryToCompressMessage(msg);
400403
}
401404

402405
LOG_DEBUG("produce before:%s to %s", msg.toString().c_str(), mq.toString().c_str());
403406

404-
tryToCompressMessage(msg);
405-
406407
SendMessageRequestHeader* requestHeader = new SendMessageRequestHeader();
407408
requestHeader->producerGroup = getGroupName();
408409
requestHeader->topic = (msg.getTopic());

0 commit comments

Comments
 (0)