gateway: queue parameters casing (livepeer#3244)

joinhive-ai · Nov 8, 2024 · 832c8ae · 832c8ae
1 parent 3441125
commit 832c8ae
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/cmd/livepeer/livepeer.go b/cmd/livepeer/livepeer.go
@@ -223,10 +223,10 @@ func parseLivepeerConfig() starter.LivepeerConfig {
 	cfg.TestOrchAvail = flag.Bool("startupAvailabilityCheck", *cfg.TestOrchAvail, "Set to false to disable the startup Orchestrator availability check on the configured serviceAddr")
 
 	// Gateway metrics
-	cfg.KafkaBootstrapServers = flag.String("kafka-bootstrap-servers", *cfg.KafkaBootstrapServers, "URL of Kafka Bootstrap Servers")
-	cfg.KafkaUsername = flag.String("kafka-user", *cfg.KafkaUsername, "Kafka Username")
-	cfg.KafkaPassword = flag.String("kafka-password", *cfg.KafkaPassword, "Kafka Password")
-	cfg.KafkaGatewayTopic = flag.String("kafka-gateway-topic", *cfg.KafkaGatewayTopic, "Kafka Topic used to send gateway logs")
+	cfg.KafkaBootstrapServers = flag.String("kafkaBootstrapServers", *cfg.KafkaBootstrapServers, "URL of Kafka Bootstrap Servers")
+	cfg.KafkaUsername = flag.String("kafkaUser", *cfg.KafkaUsername, "Kafka Username")
+	cfg.KafkaPassword = flag.String("kafkaPassword", *cfg.KafkaPassword, "Kafka Password")
+	cfg.KafkaGatewayTopic = flag.String("kafkaGatewayTopic", *cfg.KafkaGatewayTopic, "Kafka Topic used to send gateway logs")
 
 	return cfg
 }