diff --git a/pkg/common/kafka/producer.go b/pkg/common/kafka/producer.go index d736f0798..217a22c97 100644 --- a/pkg/common/kafka/producer.go +++ b/pkg/common/kafka/producer.go @@ -18,6 +18,7 @@ import ( "bytes" "context" "errors" + "fmt" "strings" "time" @@ -28,8 +29,6 @@ import ( "github.com/OpenIMSDK/tools/log" "github.com/OpenIMSDK/tools/mcontext" "google.golang.org/protobuf/proto" - - "fmt" ) const maxRetry = 10 // number of retries