[ISSUE apache#7676] use clientDecode for consuming message directly (a…

…pache#7677) Co-authored-by: dengzhiwen1 <[email protected]>
123monkey · Dec 20, 2023 · c101216 · c101216
1 parent 403ad6f
commit c101216
Showing 1 changed file with 1 addition and 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
@@ -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());