fix: RHINENG-8659 support multi kafka broker (#145)

RedHatInsights · Mar 7, 2024 · 14adcc0 · 14adcc0
1 parent bfdfda7
commit 14adcc0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/util/kafka.go b/internal/util/kafka.go
@@ -59,7 +59,7 @@ func (k kafkautil) NewWriter(topic string) *kafka.Writer {
 	}
 
 	return &kafka.Writer{
-		Addr:      kafka.TCP(config.DefaultConfig.KafkaBrokers.Values[0]),
+		Addr:      kafka.TCP(config.DefaultConfig.KafkaBrokers.Values...),
 		Topic:     topic,
 		Transport: transport,
 	}