From f6f7139d2f2be5bed2c781b09f54776d6127f9ef Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Mon, 3 Mar 2025 10:43:41 +0300
Subject: [PATCH] fixup panic

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

diff --git a/kgo.go b/kgo.go
index 0e990f0..212060d 100644
--- a/kgo.go
+++ b/kgo.go
@@ -404,6 +404,7 @@ func (k *Broker) Subscribe(ctx context.Context, topic string, handler broker.Han
 		consumers:    make(map[tp]*consumer),
 		done:         make(chan struct{}),
 		fatalOnError: fatalOnError,
+		connected:    k.connected,
 	}
 
 	kopts := append(k.kopts,