From 2404693bd22a336a65158a107dc5d62b8d282269 Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Thu, 12 Dec 2019 15:07:12 +0800 Subject: [PATCH] fix issue #66 --- plugins/bridge/kafka.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugins/bridge/kafka.go b/plugins/bridge/kafka.go index 6f7c87d..a88432d 100644 --- a/plugins/bridge/kafka.go +++ b/plugins/bridge/kafka.go @@ -29,7 +29,7 @@ type kafka struct { //Init init kafak client func InitKafka() *kafka { log.Info("start connect kafka....") - content, err := ioutil.ReadFile("./plugins/mq/kafka/kafka.json") + content, err := ioutil.ReadFile("./plugins/kafka/kafka.json") if err != nil { log.Fatal("Read config file error: ", zap.Error(err)) }