Compare commits

...

1 Commits

Author SHA1 Message Date
eaea14e5a8 fixup connected status
All checks were successful
test / test (push) Successful in 3m3s
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2025-03-07 11:26:34 +03:00

3
kgo.go
View File

@@ -143,6 +143,9 @@ func (k *Broker) connect(ctx context.Context, opts ...kgo.Opt) (*kgo.Client, *ho
return nil, nil, err return nil, nil, err
} }
} }
k.connected.Store(1)
return c, htracer, nil return c, htracer, nil
} }