diff --git a/broker/broker.go b/broker/broker.go
index fe9ddb8..1ab33ea 100644
--- a/broker/broker.go
+++ b/broker/broker.go
@@ -272,6 +272,7 @@ func (b *Broker) handleConnection(typ int, conn net.Conn) {
 	packet, err := packets.ReadPacket(conn)
 	if err != nil {
 		log.Error("read connect packet error: ", zap.Error(err))
+		conn.Close()
 		return
 	}
 	if packet == nil {