Open
Description
Hello!
In production, several times is necessary to use kafka cluster, [IP1:port, IP2:port, IP3:port, ...]. In this moment, the Gofr version only receive one broker (en several examples localhost:9092). Please, increment this characteristic in new version
for example, configs/.env:
PUBSUB_BROKERS=10.100.10.11:9092,10.100.10.13:9092, 10.100.10.15:9092
brokers := strings.Split(PUBSUB_BROKERS, ",")
kafka.NewReader(kafka.ReaderConfig{
brokers: brokers,
...
}
Thanks!