From 496c141f3523b19ee3820f68224a432b0ccd5c4e Mon Sep 17 00:00:00 2001 From: luhaoling <2198702716@qq.com> Date: Tue, 30 Jan 2024 10:12:21 +0800 Subject: [PATCH] fix: fix the kafka client close error --- go.mod | 4 ++-- go.sum | 8 ++++---- tools/component/component.go | 1 + 3 files changed, 7 insertions(+), 6 deletions(-) diff --git a/go.mod b/go.mod index 81819d2ce..81e503adf 100644 --- a/go.mod +++ b/go.mod @@ -141,7 +141,7 @@ require ( google.golang.org/genproto/googleapis/rpc v0.0.0-20231012201019-e917dd12ba7a // indirect gopkg.in/src-d/go-billy.v4 v4.3.2 // indirect gopkg.in/warnings.v0 v0.1.2 // indirect - gorm.io/gorm v1.25.2-0.20230530020048-26663ab9bf55 // indirect + gorm.io/gorm v1.25.4 // indirect stathat.com/c/consistent v1.0.0 // indirect ) @@ -159,4 +159,4 @@ require ( replace github.com/OpenIMSDK/protocol v0.0.47 => github.com/AndrewZuo01/protocol v0.0.0-20240112093520-fd9c53e27b94 -replace github.com/OpenIMSDK/tools v0.0.28 => github.com/luhaoling/tools v0.0.0-20240129093731-a82c07b43a68 +replace github.com/OpenIMSDK/tools v0.0.28 => github.com/luhaoling/tools v0.0.0-20240130020646-99b2c8e8e93a diff --git a/go.sum b/go.sum index bea16c2d8..9b06a2152 100644 --- a/go.sum +++ b/go.sum @@ -224,8 +224,8 @@ github.com/lestrrat-go/strftime v1.0.6 h1:CFGsDEt1pOpFNU+TJB0nhz9jl+K0hZSLE205Ah github.com/lestrrat-go/strftime v1.0.6/go.mod h1:f7jQKgV5nnJpYgdEasS+/y7EsTb8ykN2z68n3TtcTaw= github.com/lithammer/shortuuid v3.0.0+incompatible h1:NcD0xWW/MZYXEHa6ITy6kaXN5nwm/V115vj2YXfhS0w= github.com/lithammer/shortuuid v3.0.0+incompatible/go.mod h1:FR74pbAuElzOUuenUHTK2Tciko1/vKuIKS9dSkDrA4w= -github.com/luhaoling/tools v0.0.0-20240129093731-a82c07b43a68 h1:2bDshGtp6ETBMzsqLuThqYdmZ/+uJMgNn61Zkt3PrVE= -github.com/luhaoling/tools v0.0.0-20240129093731-a82c07b43a68/go.mod h1:ToR1sEcu7zWTl25g8h64Wko62zg6FMV8n0Ohw4r2CvY= +github.com/luhaoling/tools v0.0.0-20240130020646-99b2c8e8e93a h1:VvBUSmFgbXKucyWbkdA8nm0HRLKSg52NOCPXw41YN+4= +github.com/luhaoling/tools v0.0.0-20240130020646-99b2c8e8e93a/go.mod h1:wBfR5CYmEyvxl03QJbTkhz1CluK6J4/lX0lviu8JAjE= github.com/mattn/go-isatty v0.0.19 h1:JITubQf0MOLdlGRuRq+jtsDlekdYPia9ZFsB8h/APPA= github.com/mattn/go-isatty v0.0.19/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= github.com/matttproud/golang_protobuf_extensions v1.0.4 h1:mmDVorXM7PCGKw94cs5zkfA9PSy5pEvNWRP0ET0TIVo= @@ -530,8 +530,8 @@ gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= -gorm.io/gorm v1.25.2-0.20230530020048-26663ab9bf55 h1:sC1Xj4TYrLqg1n3AN10w871An7wJM0gzgcm8jkIkECQ= -gorm.io/gorm v1.25.2-0.20230530020048-26663ab9bf55/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k= +gorm.io/gorm v1.25.4 h1:iyNd8fNAe8W9dvtlgeRI5zSVZPsq3OpcTu37cYcpCmw= +gorm.io/gorm v1.25.4/go.mod h1:L4uxeKpfBml98NYqVqwAdmV1a2nBtAec/cf3fpucW/k= gotest.tools v2.2.0+incompatible h1:VsBPFP1AI068pPrMxtb/S8Zkgf9xEmTLJjfM+P5UIEo= gotest.tools v2.2.0+incompatible/go.mod h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81HFBacw= honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= diff --git a/tools/component/component.go b/tools/component/component.go index e1407c381..04c391471 100644 --- a/tools/component/component.go +++ b/tools/component/component.go @@ -266,6 +266,7 @@ func checkKafka() (string, error) { if err != nil { return "", err } + defer kafkaClient.Close() // Verify if necessary topics exist topics, err := kafkaClient.Topics()