[pulsar] branch master updated: ZKMetadataStore Use ZK_SCHEME_IDENTIFIER instead (#14394)

[eolivelli]

This is an automated email from the ASF dual-hosted git repository.

eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c153dea  ZKMetadataStore Use ZK_SCHEME_IDENTIFIER instead (#14394)
c153dea is described below

commit c153dea98e654c16d11758fcbfdba87cc580acf3
Author: gaozhangmin <gaozhangmin...@qq.com>
AuthorDate: Tue Feb 22 02:32:13 2022 +0800

    ZKMetadataStore Use ZK_SCHEME_IDENTIFIER instead (#14394)
    
    Co-authored-by: gavingaozhangmin <gavingaozhang...@didiglobal.com>
---
 .../main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
index cd20295..6697934 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java
@@ -81,8 +81,8 @@ public class ZKMetadataStore extends 
AbstractBatchedMetadataStore
         super(metadataStoreConfig);
 
         try {
-            if (metadataURL.startsWith("zk:")) {
-                this.zkConnectString = metadataURL.substring(3);
+            if (metadataURL.startsWith(ZK_SCHEME_IDENTIFIER)) {
+                this.zkConnectString = 
metadataURL.substring(ZK_SCHEME_IDENTIFIER.length());
             } else {
                 this.zkConnectString = metadataURL;
             }