升级 kafka 版本

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                = ""