From e064ef3af167aff4ae1fc90576ee7bdb87ba4c24 Mon Sep 17 00:00:00 2001
From: slaventius <slaventius@mail.ru>
Date: Tue, 14 Mar 2023 15:24:40 +0300
Subject: [PATCH] *

---
 internal/transport/kafka/writer.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/internal/transport/kafka/writer.go b/internal/transport/kafka/writer.go
index a760c22..27900cb 100644
--- a/internal/transport/kafka/writer.go
+++ b/internal/transport/kafka/writer.go
@@ -51,7 +51,8 @@ func (s *KafkaWriter) createTopic() error {
 	// 	return era
 	// }
 
-	// //
+	//
+	controllerConn := conn
 	// controllerConn, eru := kafka.Dial("tcp", net.JoinHostPort(controller.Host, strconv.Itoa(controller.Port)))
 	// if eru != nil {
 	// 	return eru
@@ -67,7 +68,7 @@ func (s *KafkaWriter) createTopic() error {
 		},
 	}
 
-	return conn.CreateTopics(topicConfigs...)
+	return controllerConn.CreateTopics(topicConfigs...)
 }
 
 func (s *KafkaWriter) checkTopic() error {