Switch kafka producer to use gatewayHost config

livepeer · Feb 11, 2025 · 1898848 · 1898848
1 parent b675d4a
commit 1898848
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/cmd/livepeer/starter/kafka.go b/cmd/livepeer/starter/kafka.go
@@ -11,16 +11,16 @@ func startKafkaProducer(cfg LivepeerConfig) error {
 		return nil
 	}
 
-	var broadcasterEthAddress = ""
-	if cfg.EthAcctAddr != nil {
-		broadcasterEthAddress = *cfg.EthAcctAddr
+	var gatewayHost = ""
+	if cfg.GatewayHost != nil {
+		gatewayHost = *cfg.GatewayHost
 	}
 
 	return lpmon.InitKafkaProducer(
 		*cfg.KafkaBootstrapServers,
 		*cfg.KafkaUsername,
 		*cfg.KafkaPassword,
 		*cfg.KafkaGatewayTopic,
-		broadcasterEthAddress,
+		gatewayHost,
 	)
 }