go/starter
1
0
Fork 0
mirror of https://github.com/ManyakRus/starter.git synced 2025-11-30 23:44:42 +02:00
Code Issues Releases Activity

сделал make mod

Browse Source
This commit is contained in:
Nikitin Aleksandr
2024-11-12 15:11:34 +03:00
parent 311ddd2a3e
commit a7709b057a
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
kafka_connect/kafka_connect.go
View File

@@ -36,7 +36,7 @@ type SettingsINI struct {
// Client - клиент для Kafka
var Client *kafka.Client
// Connect - подключается к серверу Nats
// Connect - подключается к серверу Kafka
func Connect() {
var err error
@@ -54,7 +54,7 @@ func LogInfo_Connected(err error) {
}
// Connect_err - подключается к серверу Nats и возвращает ошибку
// Connect_err - подключается к серверу Kafka и возвращает ошибку
func Connect_err() error {
var err error
@@ -143,7 +143,7 @@ func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup) error {
return err
}
// CloseConnection - закрывает соединение с сервером Nats
// CloseConnection - закрывает соединение с сервером Kafka
func CloseConnection() {
var err error
@@ -158,6 +158,9 @@ func CloseConnection() {
log.Info("KAFKA stopped")
}
//
Client = nil
return
}