Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
3
kgo.go
3
kgo.go
@@ -143,10 +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)
|
k.connected.Store(1)
|
||||||
}
|
|
||||||
|
|
||||||
return c, htracer, nil
|
return c, htracer, nil
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func (k *Broker) Connect(ctx context.Context) error {
|
func (k *Broker) Connect(ctx context.Context) error {
|
||||||
if k.connected.Load() == 1 {
|
if k.connected.Load() == 1 {
|
||||||
|
Reference in New Issue
Block a user