loadCoordinator: patch HEAD^^

... ... very shortly I will no longer be developing primarily on a mac

pkg/kgo/client.go

@@ -787,15 +787,15 @@ type coordinatorLoad struct {
 func (cl *Client) loadCoordinator(reload bool, ctx context.Context, key coordinatorKey) (*broker, error) {
 	cl.coordinatorsMu.Lock()
 	c, ok := cl.coordinators[key]
-	if !ok {
+	if reload || !ok {
 		c = &coordinatorLoad{
 			done: make(chan struct{}), // all requests for the same coordinator get collapsed into one
 		}
 		defer func() {
 			if c.err != nil { // if our load fails, we avoid caching the coordinator
 				cl.coordinatorsMu.Lock()
 				delete(cl.coordinators, key)
-				cl.coordinatorsMu.Lock()
+				cl.coordinatorsMu.Unlock()
 			}
 			close(c.done)
 		}()