feat: support tls:// schema to auto enable tls

streamnative · Nov 15, 2024 · 7023a65 · 7023a65
1 parent b071de7
commit 7023a65
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/client/src/main/java/io/streamnative/oxia/client/grpc/OxiaStub.java b/client/src/main/java/io/streamnative/oxia/client/grpc/OxiaStub.java
@@ -40,6 +40,7 @@
 
 @Slf4j
 public class OxiaStub implements AutoCloseable {
+    public static String TLS_SCHEMA = "tls://";
     private final ManagedChannel channel;
     private final @NonNull OxiaClientGrpc.OxiaClientStub asyncStub;
 
@@ -50,7 +51,7 @@ public OxiaStub(
             @Nullable BackoffPolicy.Provider backoffProvider) {
         this(Grpc.newChannelBuilder(
                                 address,
-                                enableTls
+                                enableTls || address.startsWith(TLS_SCHEMA)
                                         ? TlsChannelCredentials.newBuilder().build()
                                         : InsecureChannelCredentials.create())
                         .directExecutor()