diff --git a/pkg/acquisition/modules/loki/internal/lokiclient/loki_client.go b/pkg/acquisition/modules/loki/internal/lokiclient/loki_client.go
index 1c22e4727..bdf318fdf 100644
--- a/pkg/acquisition/modules/loki/internal/lokiclient/loki_client.go
+++ b/pkg/acquisition/modules/loki/internal/lokiclient/loki_client.go
@@ -186,8 +186,8 @@ func (lc *LokiClient) Tail(ctx context.Context) (chan *LokiResponse, error) {
 			err = conn.ReadJSON(jsonResponse)
 
 			if err != nil {
-				lc.Logger.Errorf("Websocket write: %s, raw: %s", err, jsonResponse)
-				return fmt.Errorf("Websocket write: %s, raw: %s", err, jsonResponse)
+				lc.Logger.Errorf("Error reading from websocket: %s", err)
+				return fmt.Errorf("websocket error: %w", err)
 			}
 
 			responseChan <- jsonResponse