diff --git a/kafka.go b/kafka.go
index f3d915d..d579317 100644
--- 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()