Fixes #83 - add the broker id when creating the Broker client via Zoo…

…keeper
newrelic · May 13, 2020 · 7c3ef1f · 7c3ef1f
1 parent 262cd87
commit 7c3ef1f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/connection/connection.go b/src/connection/connection.go
@@ -372,6 +372,7 @@ func GetBrokerFromZookeeper(zkConn zookeeper.Connection, id, preferredListener s
 			log.Warn("Failed creating client: %s", err)
 			continue
 		}
+		newBroker.ID = id
 
 		return newBroker, nil
 	}