diff --git a/kgo.go b/kgo.go
index d723ea3..b6f689a 100644
--- a/kgo.go
+++ b/kgo.go
@@ -142,10 +142,9 @@ func (k *Broker) connect(ctx context.Context, opts ...kgo.Opt) (*kgo.Client, *ho
 			}
 			return nil, nil, err
 		}
+		k.connected.Store(1)
 	}
 
-	k.connected.Store(1)
-
 	return c, htracer, nil
 }