hornbill: update server command args

hstreamdb · Nov 14, 2024 · 57870b9 · 57870b9
1 parent 9053e9b
commit 57870b9
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/app/src/main/scala/hstream/server/KafkaBroker.scala b/app/src/main/scala/hstream/server/KafkaBroker.scala
@@ -236,6 +236,7 @@ class KafkaBroker(
             val metaServerCmd =
               s"""docker run -d --network host --name $metaServerContainerName -v $storeConfig:$storeConfig:ro
                 $image hornbill meta --host 127.0.0.1 --port $metaServerPort
+                --metrics-port 0
                 --backend $storeConfig
             """.stripMargin.linesIterator.mkString(" ").trim
             info(s"=> Start meta server by: $metaServerCmd")

diff --git a/app/src/main/scala/hstream/server/KafkaConfig.scala b/app/src/main/scala/hstream/server/KafkaConfig.scala
@@ -412,6 +412,7 @@ object TestConfig {
     }
   }
 
+  // === spec 1: hstream
   private def parseTestingConfig1(
       brokerConfig: collection.mutable.Map[String, Object],
       testingConfig: collection.mutable.Map[String, Object],
@@ -491,6 +492,7 @@ object TestConfig {
     }
   }
 
+  // === spec 2: hornbill
   private def parseTestingConfig2(
       brokerConfig: collection.mutable.Map[String, Object],
       testingConfig: collection.mutable.Map[String, Object],
@@ -549,7 +551,8 @@ object TestConfig {
       brokerConfig.foreach { case (k, v) => prop.put(k, v.toString) }
       // testing config
       val args = s"""--server-id $nodeId
-                --port $port --advertised-address $advertisedAddress
+                --listeners plaintext://0.0.0.0:$port
+                --advertised-listeners plaintext://$advertisedAddress:$port
                 --meta-servers http://127.0.0.1:$metaServerPort
                 --store-config $storeConfig
                 """.stripMargin.linesIterator.mkString(" ").trim