From cd4c1a5a3aa76cf7cd9d193c3b80e14c30b3c645 Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Mon, 15 Jul 2019 11:53:54 +0800 Subject: [PATCH] add log --- plugins/kafka/kafka.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/plugins/kafka/kafka.go b/plugins/kafka/kafka.go index fe76bb4..5852709 100644 --- a/plugins/kafka/kafka.go +++ b/plugins/kafka/kafka.go @@ -36,12 +36,15 @@ type Config struct { //Init init kafak client func Init() { + log.Info("start connect kafka....") content, err := ioutil.ReadFile("./plugins/kafka/kafka.json") if err != nil { log.Fatal("Read config file error: ", zap.Error(err)) } // log.Info(string(content)) + log.Info("end connect kafka....") + err = json.Unmarshal(content, &config) if err != nil { log.Fatal("Unmarshal config file error: ", zap.Error(err))