This commit is contained in:
joy.zhou
2019-12-12 15:07:12 +08:00
parent 68cd5e94a4
commit 2404693bd2
+1 -1
View File
@@ -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))
}