From 1898848034fdef9aab81723358194aae0c32b086 Mon Sep 17 00:00:00 2001 From: Max Holland Date: Tue, 11 Feb 2025 14:07:11 +0000 Subject: [PATCH] Switch kafka producer to use gatewayHost config --- cmd/livepeer/starter/kafka.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/cmd/livepeer/starter/kafka.go b/cmd/livepeer/starter/kafka.go index 880b04f1f1..e6f9d8e27e 100644 --- a/cmd/livepeer/starter/kafka.go +++ b/cmd/livepeer/starter/kafka.go @@ -11,9 +11,9 @@ 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( @@ -21,6 +21,6 @@ func startKafkaProducer(cfg LivepeerConfig) error { *cfg.KafkaUsername, *cfg.KafkaPassword, *cfg.KafkaGatewayTopic, - broadcasterEthAddress, + gatewayHost, ) }