diff --git a/waku/v2/peermanager/peer_discovery.go b/waku/v2/peermanager/peer_discovery.go
index ae18907c..8ab1c8be 100644
--- a/waku/v2/peermanager/peer_discovery.go
+++ b/waku/v2/peermanager/peer_discovery.go
@@ -112,7 +112,7 @@ func (pm *PeerManager) discoverPeersByPubsubTopics(pubsubTopics []string, proto
 		for _, shardInfo := range shardsInfo {
 			err = pm.DiscoverAndConnectToPeers(ctx, shardInfo.ClusterID, shardInfo.ShardIDs[0], proto, maxCount)
 			if err != nil {
-				pm.logger.Error("failed to discover and connect to peers", zap.Error(err))
+				pm.logger.Warn("failed to discover and connect to peers", zap.Error(err))
 			}
 		}
 	} else {
diff --git a/waku/v2/protocol/peer_exchange/protocol.go b/waku/v2/protocol/peer_exchange/protocol.go
index 5f103e12..08e5051c 100644
--- a/waku/v2/protocol/peer_exchange/protocol.go
+++ b/waku/v2/protocol/peer_exchange/protocol.go
@@ -98,7 +98,7 @@ func (wakuPX *WakuPeerExchange) onRequest() func(network.Stream) {
 
 		if wakuPX.limiter != nil && !wakuPX.limiter.Allow() {
 			wakuPX.metrics.RecordError(rateLimitFailure)
-			wakuPX.log.Error("exceeds the rate limit")
+			wakuPX.log.Info("exceeds the rate limit")
 			// TODO: peer exchange protocol should contain an err field
 			if err := stream.Reset(); err != nil {
 				wakuPX.log.Error("resetting connection", zap.Error(err))