diff --git a/core/src/main/java/io/questdb/cutlass/pgwire/PGConnectionContext.java b/core/src/main/java/io/questdb/cutlass/pgwire/PGConnectionContext.java
index 34dd11832e69206759c792462a42ebd3ae14bbca..195120e5bcda93d05d25ea814454102d769917de 100644
--- a/core/src/main/java/io/questdb/cutlass/pgwire/PGConnectionContext.java
+++ b/core/src/main/java/io/questdb/cutlass/pgwire/PGConnectionContext.java
@@ -1063,7 +1063,7 @@ public class PGConnectionContext implements IOContext, Mutable, WriterSource {
         }
 
         if (n < size) {
-            doSendWithRetries(n, size - n);
+            doSendWithRetries(offset + n, size - n);
         }
         sendBufferPtr = sendBuffer;
         bufferRemainingSize = 0;