fixed

broker/broker.go

@@ -328,7 +328,7 @@ func (b *Broker) handleConnection(typ int, conn net.Conn) {
 		return
 	}
 
-	log.Info("reconnect connect from ", zap.String("clientID", msg.ClientIdentifier))
+	log.Info("read connect from ", zap.String("clientID", msg.ClientIdentifier))
 
 	connack := packets.NewControlPacket(packets.Connack).(*packets.ConnackPacket)
 	connack.ReturnCode = packets.Accepted

logger/logger.go

@@ -16,6 +16,7 @@ var (
 // NewDevLogger return a logger for dev builds
 func NewDevLogger() (*zap.Logger, error) {
 	logCfg := zap.NewDevelopmentConfig()
+	// logCfg.Level = zap.NewAtomicLevelAt(zap.DebugLevel)
 	logCfg.DisableStacktrace = true
 	return logCfg.Build()
 }

plugins/authhttp/authhttp.go

@@ -2,7 +2,6 @@ package authhttp
 
 import (
 	"encoding/json"
-	"fmt"
 	"io/ioutil"
 	"net/http"
 	"net/url"
@@ -44,7 +43,7 @@ func Init() {
 	if err != nil {
 		log.Fatal("Unmarshal config file error: ", zap.Error(err))
 	}
-	fmt.Println("http: config: ", config)
+	// fmt.Println("http: config: ", config)
 
 	httpClient = &http.Client{
 		Transport: &http.Transport{