From 2e5f48ffa6c392f31bfff68596fcff673c1c46bb Mon Sep 17 00:00:00 2001
From: Li Zhanhui <lizhanhui@gmail.com>
Date: Fri, 10 Nov 2023 17:18:23 +0800
Subject: [PATCH] fix local mode by making ext-headers remoting protocol
 compliant

Signed-off-by: Li Zhanhui <lizhanhui@gmail.com>
---
 .../rocketmq/proxy/service/message/LocalRemotingCommand.java     | 1 +
 1 file changed, 1 insertion(+)

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
index 915cafcd579..7bf4a169820 100644
--- 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;
     }