From 397f5414b34cbb6a61cb78b13c3e8c5490f95a24 Mon Sep 17 00:00:00 2001
From: Evstigneev Denis <danteevstigneev@yandex.ru>
Date: Wed, 21 May 2025 11:36:28 +0300
Subject: [PATCH] removed reconn

---
 kgo.go | 13 -------------
 1 file changed, 13 deletions(-)

diff --git a/kgo.go b/kgo.go
index e957fae..6ad858f 100644
--- a/kgo.go
+++ b/kgo.go
@@ -280,19 +280,6 @@ func (k *Broker) Publish(ctx context.Context, topic string, msg *broker.Message,
 }
 
 func (k *Broker) publish(ctx context.Context, msgs []*broker.Message, opts ...broker.PublishOption) error {
-	k.Lock()
-	if k.connected.Load() == 0 {
-		c, _, err := k.connect(ctx, k.kopts...)
-		if err != nil {
-			k.Unlock()
-			return err
-		}
-		k.c.Close()
-		k.c = c
-		k.connected.Store(1)
-	}
-	k.Unlock()
-
 	options := broker.NewPublishOptions(opts...)
 	records := make([]*kgo.Record, 0, len(msgs))
 	var errs []string