From e257da5c06c74423b5bed0e0d15e1d9d597e781e Mon Sep 17 00:00:00 2001
From: slaventius <slaventius@mail.ru>
Date: Wed, 8 Feb 2023 11:10:51 +0300
Subject: [PATCH] *

---
 .vscode/launch.json                |  1 +
 internal/transport/kafka/writer.go | 27 +++++++++++++--------------
 scripts/start.sh                   |  3 ++-
 3 files changed, 16 insertions(+), 15 deletions(-)

diff --git a/.vscode/launch.json b/.vscode/launch.json
index 05f4473..3525e68 100644
--- a/.vscode/launch.json
+++ b/.vscode/launch.json
@@ -13,6 +13,7 @@
       "env": {
         "APP_PORT":"9995",
         "KAFKA_PORT":"9092",
+        "KAFKA_HOST":"37.143.12.169",
       },
       "args": []
     }
diff --git a/internal/transport/kafka/writer.go b/internal/transport/kafka/writer.go
index aa1e9cf..eb5b441 100644
--- a/internal/transport/kafka/writer.go
+++ b/internal/transport/kafka/writer.go
@@ -3,8 +3,6 @@ package kafka
 import (
 	"context"
 	"log"
-	"net"
-	"strconv"
 	"time"
 
 	"github.com/segmentio/kafka-go"
@@ -46,18 +44,18 @@ func (s *KafkaWriter) createTopic() error {
 	}
 	defer conn.Close()
 
-	//
-	controller, era := conn.Controller()
-	if era != nil {
-		return era
-	}
+	// //
+	// controller, era := conn.Controller()
+	// if era != nil {
+	// 	return era
+	// }
 
-	//
-	controllerConn, eru := kafka.Dial("tcp", net.JoinHostPort(controller.Host, strconv.Itoa(controller.Port)))
-	if eru != nil {
-		return eru
-	}
-	defer controllerConn.Close()
+	// //
+	// controllerConn, eru := kafka.Dial("tcp", net.JoinHostPort(controller.Host, strconv.Itoa(controller.Port)))
+	// if eru != nil {
+	// 	return eru
+	// }
+	// defer controllerConn.Close()
 
 	//
 	topicConfigs := []kafka.TopicConfig{
@@ -68,7 +66,7 @@ func (s *KafkaWriter) createTopic() error {
 		},
 	}
 
-	return controllerConn.CreateTopics(topicConfigs...)
+	return conn.CreateTopics(topicConfigs...)
 }
 
 func (s *KafkaWriter) checkTopic() error {
@@ -99,6 +97,7 @@ func NewWriter(ctx context.Context, topic string, address ...string) *KafkaWrite
 			Topic:           topic,
 			Balancer:        &kafka.LeastBytes{},
 			WriteBackoffMax: time.Millisecond * 100,
+			BatchTimeout:    time.Millisecond * 100,
 			Addr:            kafka.TCP(address...),
 		},
 		first: address[0],
diff --git a/scripts/start.sh b/scripts/start.sh
index 89fe147..666d7f8 100755
--- a/scripts/start.sh
+++ b/scripts/start.sh
@@ -3,5 +3,6 @@
 export APP_PORT=9995
 export KAFKA_PORT=9092
 export KAFKA_HOST=127.0.0.1
+export KAFKA_HOST=37.143.12.169
 
-./authDBService
\ No newline at end of file
+./authDBService