diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java b/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java index c1db9e366..781f1977f 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java @@ -43,6 +43,7 @@ public class Signature { public static final String LANGUAGE_KEY = "x-mq-language"; public static final String CLIENT_VERSION_KEY = "x-mq-client-version"; public static final String PROTOCOL_VERSION = "x-mq-protocol"; + public static final String NAMESPACE_KEY = "x-mq-namespace"; public static final String ALGORITHM = "MQv2-HMAC-SHA1"; public static final String CREDENTIAL = "Credential"; @@ -69,6 +70,7 @@ public static Metadata sign(ClientConfiguration config, ClientId clientId) throw metadata.put(Metadata.Key.of(REQUEST_ID_KEY, Metadata.ASCII_STRING_MARSHALLER), requestId); metadata.put(Metadata.Key.of(CLIENT_ID_KEY, Metadata.ASCII_STRING_MARSHALLER), clientId.toString()); + metadata.put(Metadata.Key.of(NAMESPACE_KEY, Metadata.ASCII_STRING_MARSHALLER), config.getNamespace()); final Optional optionalSessionCredentialsProvider = config.getCredentialsProvider();