diff --git a/p2p/conn/connection.go b/p2p/conn/connection.go
index 70bb478d3..b5290116d 100644
--- a/p2p/conn/connection.go
+++ b/p2p/conn/connection.go
@@ -323,7 +323,7 @@ func (c *MConnection) flush() {
 	c.Logger.Debug("Flush", "conn", c)
 	err := c.bufConnWriter.Flush()
 	if err != nil {
-		c.Logger.Error("MConnection flush failed", "err", err)
+		c.Logger.Debug("MConnection flush failed", "err", err)
 	}
 }
 
@@ -597,7 +597,7 @@ FOR_LOOP:
 				if err == io.EOF {
 					c.Logger.Info("Connection is closed @ recvRoutine (likely by the other side)", "conn", c)
 				} else {
-					c.Logger.Error("Connection failed @ recvRoutine (reading byte)", "conn", c, "err", err)
+					c.Logger.Debug("Connection failed @ recvRoutine (reading byte)", "conn", c, "err", err)
 				}
 				c.stopForError(err)
 			}
@@ -626,7 +626,7 @@ FOR_LOOP:
 			channel, ok := c.channelsIdx[byte(pkt.PacketMsg.ChannelID)]
 			if !ok || channel == nil {
 				err := fmt.Errorf("unknown channel %X", pkt.PacketMsg.ChannelID)
-				c.Logger.Error("Connection failed @ recvRoutine", "conn", c, "err", err)
+				c.Logger.Debug("Connection failed @ recvRoutine", "conn", c, "err", err)
 				c.stopForError(err)
 				break FOR_LOOP
 			}
@@ -634,7 +634,7 @@ FOR_LOOP:
 			msgBytes, err := channel.recvPacketMsg(*pkt.PacketMsg)
 			if err != nil {
 				if c.IsRunning() {
-					c.Logger.Error("Connection failed @ recvRoutine", "conn", c, "err", err)
+					c.Logger.Debug("Connection failed @ recvRoutine", "conn", c, "err", err)
 					c.stopForError(err)
 				}
 				break FOR_LOOP
diff --git a/p2p/peer.go b/p2p/peer.go
index 4fdb4ee57..36db3d728 100644
--- a/p2p/peer.go
+++ b/p2p/peer.go
@@ -201,7 +201,7 @@ func (p *peer) OnStop() {
 	p.metricsTicker.Stop()
 	p.BaseService.OnStop()
 	if err := p.mconn.Stop(); err != nil { // stop everything and close the conn
-		p.Logger.Error("Error while stopping peer", "err", err)
+		p.Logger.Debug("Error while stopping peer", "err", err)
 	}
 }