fix:support higher version grpc. (#447)

polarismesh · Nov 27, 2023 · c5aa159 · c5aa159
1 parent d482a1a
commit c5aa159
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/GrpcUtil.java b/...ector-polaris-grpc/src/main/java/com/tencent/polaris/plugins/connector/grpc/GrpcUtil.java
@@ -152,7 +152,7 @@ public static String nextReportServiceContractReqId() {
     public static <T extends AbstractStub<T>> void attachRequestHeader(T stub, String nextID) {
         Metadata extraHeaders = new Metadata();
         extraHeaders.put(KEY_REQUEST_ID, nextID);
-        MetadataUtils.attachHeaders(stub, extraHeaders);
+        stub.withInterceptors(MetadataUtils.newAttachHeadersInterceptor(extraHeaders));
     }
 
     /**
@@ -170,7 +170,7 @@ public static <T extends AbstractStub<T>> void attachRequestHeader(T stub, Map<S
         for (Entry<String, String> header : customHeader.entrySet()) {
             customMetadata.put(Metadata.Key.of(header.getKey(), Metadata.ASCII_STRING_MARSHALLER), header.getValue());
         }
-        MetadataUtils.attachHeaders(stub, customMetadata);
+        stub.withInterceptors(MetadataUtils.newAttachHeadersInterceptor(customMetadata));
     }
 
     public static void checkResponse(ResponseProto.Response response) throws PolarisException {