From c10121697ae50ad19ac0dea1ef22690caba14e99 Mon Sep 17 00:00:00 2001 From: cserwen Date: Wed, 20 Dec 2023 10:12:15 +0800 Subject: [PATCH] [ISSUE #7676] use clientDecode for consuming message directly (#7677) Co-authored-by: dengzhiwen1 --- .../apache/rocketmq/client/impl/ClientRemotingProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java index 31b879ffed0..2f18c610c14 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java @@ -208,7 +208,7 @@ private RemotingCommand consumeMessageDirectly(ChannelHandlerContext ctx, (ConsumeMessageDirectlyResultRequestHeader) request .decodeCommandCustomHeader(ConsumeMessageDirectlyResultRequestHeader.class); - final MessageExt msg = MessageDecoder.decode(ByteBuffer.wrap(request.getBody())); + final MessageExt msg = MessageDecoder.clientDecode(ByteBuffer.wrap(request.getBody()), true); ConsumeMessageDirectlyResult result = this.mqClientFactory.consumeMessageDirectly(msg, requestHeader.getConsumerGroup(), requestHeader.getBrokerName());