Merge pull request #104 from jbellister-slac/fix_broker

Fix broker configuration
slaclab · Jun 27, 2022 · 6020a13 · 6020a13
2 parents 1e0dcc7 + ad3f404
commit 6020a13
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cli/commands/start-kafka-broker b/cli/commands/start-kafka-broker
@@ -23,7 +23,7 @@ do
         --port) 
           NALMS_KAFKA_PORT=$2
             ;;
-        --port) 
+        --broker)
           BROKER_NUMBER=$2
             ;;
         "")

diff --git a/kafka/scripts/start-kafka.sh b/kafka/scripts/start-kafka.sh
@@ -55,13 +55,13 @@ if [[ "$USE_SSL" = true ]]; then
     # start ssl server
     ./opt/kafka/bin/kafka-server-start.sh /opt/kafka/server.properties --override advertised.listeners=${KAFKA_ADVERTISED_LISTENERS} \
         --override listener.security.protocol.map=${KAFKA_LISTENER_SECURITY_PROTOCOL_MAP} --override listeners=${KAFKA_LISTENERS} \
-        --override zookeeper.connect=${ZOOKEEPER_CONNECT} --override boker.id=${BROKER_ID} \
+        --override zookeeper.connect=${ZOOKEEPER_CONNECT} --override broker.id=${BROKER_ID} \
         --override ssl.keystore.password=${KEYSTORE_PASSWORD} \
         --override ssl.truststore.password=${TRUSTSTORE_PASSWORD} \
         --override ssl.key.password=${KEY_PASSWORD}
 else
     # start server
     ./opt/kafka/bin/kafka-server-start.sh /opt/kafka/server.properties --override advertised.listeners=${KAFKA_ADVERTISED_LISTENERS} \
         --override listener.security.protocol.map=${KAFKA_LISTENER_SECURITY_PROTOCOL_MAP} --override listeners=${KAFKA_LISTENERS} \
-        --override zookeeper.connect=${ZOOKEEPER_CONNECT} --override boker.id=${BROKER_ID} 
+        --override zookeeper.connect=${ZOOKEEPER_CONNECT} --override broker.id=${BROKER_ID}
 fi