auto split kafkaURL to array (segmentio#280)

auto split kafkaURL to array
huangfu · Jul 22, 2019 · e31ffda · e31ffda
1 parent 59f58f0
commit e31ffda
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/examples/consumer-logger/main.go b/examples/consumer-logger/main.go
@@ -5,13 +5,15 @@ import (
 	"fmt"
 	"log"
 	"os"
+	"strings"
 
 	kafka "github.com/segmentio/kafka-go"
 )
 
 func getKafkaReader(kafkaURL, topic, groupID string) *kafka.Reader {
+	brokers := strings.Split(kafkaURL, ",")
 	return kafka.NewReader(kafka.ReaderConfig{
-		Brokers:  []string{kafkaURL},
+		Brokers:  brokers,
 		GroupID:  groupID,
 		Topic:    topic,
 		MinBytes: 10e3, // 10KB