fix #7552

Signed-off-by: Zhanhui Li <[email protected]>
apache · Nov 10, 2023 · 4552c33 · 4552c33
1 parent f74c887
commit 4552c33
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java b/proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
@@ -32,6 +32,7 @@ public static LocalRemotingCommand createRequestCommand(int code, CommandCustomH
         cmd.writeCustomHeader(customHeader);
         cmd.setExtFields(new HashMap<>());
         setCmdVersion(cmd);
+        cmd.makeCustomHeaderToNet();
         return cmd;
     }