fixup connected status

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2025-03-07 11:45:36 +03:00 · 2025-03-07 11:44:56 +03:00
1 changed files with 2 additions and 4 deletions
--- a/kgo.go
+++ b/kgo.go
@@ -142,11 +142,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
 	}
-
-	k.connected.Store(1)
-
-	return c, htracer, nil
 }

 func (k *Broker) Connect(ctx context.Context) error {
Author	SHA1	Message	Date
Vasiliy Tolstov	f4f8793686	fixup connected status All checks were successful test / test (push) Successful in 2m25s Details Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2025-03-07 11:45:36 +03:00
Vasiliy Tolstov	ec4922ad8b	fixup connected status Some checks failed test / test (push) Has been cancelled Details Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>	2025-03-07 11:44:56 +03:00