diff --git a/pkg/rtc/room.go b/pkg/rtc/room.go
index 7ee47bc22..4fadc21da 100644
--- a/pkg/rtc/room.go
+++ b/pkg/rtc/room.go
@@ -1331,7 +1331,7 @@ func BroadcastDataPacketForRoom(r types.Room, source types.LocalParticipant, dp
 	utils.ParallelExec(destParticipants, dataForwardLoadBalanceThreshold, 1, func(op types.LocalParticipant) {
 		err := op.SendDataPacket(dp, dpData)
 		if err != nil && !errors.Is(err, io.ErrClosedPipe) && !errors.Is(err, psrpc.Canceled) &&
-			errors.Is(err, psrpc.ErrStreamClosed) {
+			!errors.Is(err, psrpc.ErrStreamClosed) {
 			op.GetLogger().Infow("send data packet error", "error", err)
 		}
 	})
diff --git a/pkg/sfu/buffer/rtpstats.go b/pkg/sfu/buffer/rtpstats.go
index 9468e1b04..e070a6fb9 100644
--- a/pkg/sfu/buffer/rtpstats.go
+++ b/pkg/sfu/buffer/rtpstats.go
@@ -838,7 +838,7 @@ func (r *RTPStats) maybeAdjustFirstPacketTime(ets uint64) {
 			"extStartTS", r.timestamp.GetExtendedStart(),
 		)
 		if r.firstTime.Sub(firstTime) > firstPacketTimeAdjustThreshold {
-			r.logger.Debugw("first packet time adjustment too big, ignoring",
+			r.logger.Infow("first packet time adjustment too big, ignoring",
 				"startTime", r.startTime.String(),
 				"nowTime", now.String(),
 				"before", r.firstTime.String(),