Merge branch 'master' into rafal/configurable-retry-processing

livepeer · Feb 11, 2025 · cbfb189 · cbfb189
2 parents 0da47be + 66ab0f9
commit cbfb189
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,
 	)
 }