[pulsar] branch master updated: [Improve][Standalone] Standalone Add param of --metadata-url for runing with metadata (#17077)

[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 3e51af5876f [Improve][Standalone] Standalone Add param of 
--metadata-url for runing with metadata (#17077)
3e51af5876f is described below

commit 3e51af5876f1c1da1a46d1278bc210d449321cf8
Author: Lan <gcs...@gmail.com>
AuthorDate: Mon Sep 26 17:44:35 2022 +0800

    [Improve][Standalone] Standalone Add param of --metadata-url for runing 
with metadata (#17077)
---
 .../main/java/org/apache/pulsar/PulsarStandalone.java   | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java 
b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
index 2f3d15b1eaf..4fd22eba785 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java
@@ -223,6 +223,10 @@ public class PulsarStandalone implements AutoCloseable {
             description = "Directory for storing metadata")
     private String metadataDir = "data/metadata";
 
+    @Parameter(names = { "--metadata-url" },
+            description = "Metadata store url")
+    private String metadataStoreUrl = "";
+
     @Parameter(names = {"--zookeeper-port"}, description = "Local zookeeper's 
port",
             hidden = true)
     private int zkPort = 2181;
@@ -290,7 +294,7 @@ public class PulsarStandalone implements AutoCloseable {
 
         if (!this.isOnlyBroker()) {
             if (usingNewDefaultsPIP117) {
-                startBookieWithRocksDB();
+                startBookieWithMetadataStore();
             } else {
                 startBookieWithZookeeper();
             }
@@ -434,10 +438,13 @@ public class PulsarStandalone implements AutoCloseable {
         }
     }
 
-
-    private void startBookieWithRocksDB() throws Exception {
-        log.info("Starting BK with RocksDb metadata store");
-        String metadataStoreUrl = "rocksdb://" + 
Paths.get(metadataDir).toAbsolutePath();
+    private void startBookieWithMetadataStore() throws Exception {
+        if (StringUtils.isBlank(metadataStoreUrl)){
+            log.info("Starting BK with RocksDb metadata store");
+            metadataStoreUrl = "rocksdb://" + 
Paths.get(metadataDir).toAbsolutePath();
+        } else {
+            log.info("Starting BK with metadata store:", metadataStoreUrl);
+        }
         bkCluster = BKCluster.builder()
                 .metadataServiceUri(metadataStoreUrl)
                 .bkPort(bkPort)