mirror of
https://github.com/fhmq/hmq.git
synced 2026-05-04 07:08:32 +00:00
fixed
This commit is contained in:
@@ -33,7 +33,7 @@ type Config struct {
|
|||||||
|
|
||||||
//Init init kafak client
|
//Init init kafak client
|
||||||
func Init() {
|
func Init() {
|
||||||
content, err := ioutil.ReadFile("/plugins/authhttp/http.json")
|
content, err := ioutil.ReadFile("./plugins/authhttp/http.json")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal("Read config file error: ", zap.Error(err))
|
log.Fatal("Read config file error: ", zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -37,7 +37,7 @@ type Config struct {
|
|||||||
//Init init kafak client
|
//Init init kafak client
|
||||||
func Init() {
|
func Init() {
|
||||||
log.Info("start connect kafka....")
|
log.Info("start connect kafka....")
|
||||||
content, err := ioutil.ReadFile("/plugins/kafka/kafka.json")
|
content, err := ioutil.ReadFile("./plugins/kafka/kafka.json")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal("Read config file error: ", zap.Error(err))
|
log.Fatal("Read config file error: ", zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user