diff --git a/main.go b/main.go
index 26b1dc3..512dba3 100644
--- a/main.go
+++ b/main.go
@@ -47,10 +47,10 @@
 
 	// config
 	broker  = flag.String("broker", "voltha-kafka.default.svc.cluster.local:9092", "The Kafka broker")
-	brokers = []string{*broker}
 	topic   = flag.String("topic", "voltha.kpis", "The Kafka topic")
 )
 
+var brokers []string
 var messageCountStart int
 
 func prefixToLabels(prefix string) (string, string, string) {
@@ -87,7 +87,7 @@
 	}
 }
 
-func kafkaInit() {
+func kafkaInit(brokers []string) {
 	config := sarama.NewConfig()
 	config.Consumer.Return.Errors = true
 
@@ -181,7 +181,9 @@
 
 	// read config from cli flags
 	flag.Parse()
-	fmt.Println("Connecting to broker: ", *broker)
+	brokers = make([]string, 0)
+	brokers = []string{*broker}
+	fmt.Println("Connecting to broker: ", brokers)
 	fmt.Println("Listening to topic: ", *topic)
 
 	// register metrics within Prometheus
@@ -192,6 +194,6 @@
 }
 
 func main() {
-	go kafkaInit()
+	go kafkaInit(brokers)
 	runServer()
 }