fixup panic

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2024-12-05 09:53:40 +03:00 · 2024-12-05 09:53:40 +03:00 · d5f2df31e0
commit d5f2df31e0
parent 90365a455c
1 changed files with 3 additions and 2 deletions
--- a/kgo.go
+++ b/kgo.go
@ -460,7 +460,8 @@ func NewBroker(opts ...broker.Option) *Broker {
 	}

 	return &Broker{
-		opts:  options,
-		kopts: kopts,
+		connected: &atomic.Uint32{},
+		opts:      options,
+		kopts:     kopts,
 	}
 }