fix readerConfig.Brokers and writerConfig.Brokers

2020-04-13 22:56:40 +08:00 · 2020-04-13 22:56:40 +08:00 · 9353991c21
commit 9353991c21
parent cba22d5cf0
1 changed files with 2 additions and 0 deletions
--- a/kafka.go
+++ b/kafka.go
@ -110,6 +110,8 @@ func (k *kBroker) Connect() error {

 	k.Lock()
 	k.addrs = kaddrs
+	k.readerConfig.Brokers = k.addrs
+	k.writerConfig.Brokers = k.addrs
 	k.connected = true
 	k.Unlock()