diff --git a/internal/util/kafka.go b/internal/util/kafka.go
index 5f010770..a72e4a78 100644
--- 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,
 	}