fixup connected status

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2025-03-07 11:45:36 +03:00
parent ec4922ad8b
commit 4c44dde012
1 changed files with 1 additions and 2 deletions
--- a/kgo.go
+++ b/kgo.go
@@ -143,10 +143,9 @@ func (k *Broker) connect(ctx context.Context, opts ...kgo.Opt) (*kgo.Client, *ho
 			return nil, nil, err
 		}
 		k.connected.Store(1)
-	}
-
 		return c, htracer, nil
 	}
+}

 func (k *Broker) Connect(ctx context.Context) error {
 	if k.connected.Load() == 1 {