diff --git a/native/src/main/java/com/velocitypowered/natives/compression/JavaVelocityCompressor.java b/native/src/main/java/com/velocitypowered/natives/compression/JavaVelocityCompressor.java
index 3a0a7d07c..c948e6ee4 100644
--- a/native/src/main/java/com/velocitypowered/natives/compression/JavaVelocityCompressor.java
+++ b/native/src/main/java/com/velocitypowered/natives/compression/JavaVelocityCompressor.java
@@ -28,7 +28,8 @@ public class JavaVelocityCompressor implements VelocityCompressor {
     ensureNotDisposed();
 
     if (source.hasArray()) {
-      inflater.setInput(source.array(), source.arrayOffset(), source.readableBytes());
+      inflater.setInput(source.array(), source.arrayOffset() + source.readerIndex(),
+          source.readableBytes());
     } else {
       byte[] inData = new byte[source.readableBytes()];
       source.readBytes(inData);
@@ -47,7 +48,8 @@ public class JavaVelocityCompressor implements VelocityCompressor {
     ensureNotDisposed();
 
     if (source.hasArray()) {
-      deflater.setInput(source.array(), source.arrayOffset(), source.readableBytes());
+      deflater.setInput(source.array(), source.arrayOffset() + source.readerIndex(),
+          source.readableBytes());
     } else {
       byte[] inData = new byte[source.readableBytes()];
       source.readBytes(inData);