fix: correct MessageExt encoding

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
apache · Oct 22, 2024 · 722e056 · 722e056
1 parent 2d271ef
commit 722e056
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java b/store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java
@@ -176,7 +176,7 @@ public PutMessageResult encodeWithoutProperties(MessageExtBrokerInner msgInner)
     public PutMessageResult encode(MessageExtBrokerInner msgInner) {
         this.byteBuf.clear();
 
-        if (messageStoreConfig.isEnableLmq() && MixAll.topicAllowsLMQ(msgInner.getTopic())) {
+        if (messageStoreConfig.isEnableLmq() && msgInner.needDispatchLMQ()) {
             return encodeWithoutProperties(msgInner);
         }