From f4f87936868db402fb21ff4a5f90d2a09cd41c18 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Fri, 7 Mar 2025 11:45:36 +0300
Subject: [PATCH] fixup connected status

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 kgo.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/kgo.go b/kgo.go
index b6f689a..1cd57df 100644
--- a/kgo.go
+++ b/kgo.go
@@ -143,9 +143,8 @@ 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
 	}
-
-	return c, htracer, nil
 }
 
 func (k *Broker) Connect(ctx context.Context) error {