diff --git a/pkg/rtc/participant_signal.go b/pkg/rtc/participant_signal.go
index e2a4bf576..0d45517f1 100644
--- a/pkg/rtc/participant_signal.go
+++ b/pkg/rtc/participant_signal.go
@@ -180,16 +180,14 @@ func (p *ParticipantImpl) writeMessage(msg *livekit.SignalResponse) error {
 
 	sink := p.getResponseSink()
 	if sink == nil {
-		err := fmt.Errorf("no response sink")
-		p.params.Logger.Warnw("could not send message to participant", err,
-			"message", fmt.Sprintf("%T", msg.Message))
-		return err
+		p.params.Logger.Infow("could not send message to participant", "messageType", fmt.Sprintf("%T", msg.Message))
+		return nil
 	}
 
 	err := sink.WriteMessage(msg)
 	if err != nil {
 		p.params.Logger.Warnw("could not send message to participant", err,
-			"message", fmt.Sprintf("%T", msg.Message))
+			"messageType", fmt.Sprintf("%T", msg.Message))
 		return err
 	}
 	return nil
diff --git a/pkg/rtc/room.go b/pkg/rtc/room.go
index f51259446..0c137f1ac 100644
--- a/pkg/rtc/room.go
+++ b/pkg/rtc/room.go
@@ -2,6 +2,8 @@ package rtc
 
 import (
 	"context"
+	"errors"
+	"io"
 	"math"
 	"sort"
 	"sync"
@@ -803,7 +805,7 @@ func (r *Room) onDataPacket(source types.LocalParticipant, dp *livekit.DataPacke
 		}
 
 		err := op.SendDataPacket(dp, dpData)
-		if err != nil {
+		if err != nil && !errors.Is(err, io.ErrClosedPipe) {
 			r.Logger.Infow("send data packet error", "error", err, "participant", op.Identity())
 		}
 	}