升级kafka版本

e4e721ce · meng.cheng · b6b2f751 · e4e721ce
Commit e4e721ce authored May 25, 2022 by meng.cheng
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

global.go pkg/global/global.go +1 -1

No files found.
--- a/pkg/global/global.go
+++ b/pkg/global/global.go
@@ -41,7 +41,7 @@ var (
 	LocalIp, _                     = util.LocalIp()
 	Config          *conf.Conf     = nil
 	Logger          *logger.Logger = nil
-	KafkaVersion                   = sarama.V1_0_0_0
+	KafkaVersion                   = sarama.V2_0_0_0
 	KafkaRecver     *kafka.Recver  = nil
 	MasterAddress                  = ""
 	InfluxDbAddress                = ""