diff --git a/native/src/main/java/com/velocitypowered/natives/compression/Java11VelocityCompressor.java b/native/src/main/java/com/velocitypowered/natives/compression/Java11VelocityCompressor.java
index 034126bc8..999d12caa 100644
--- a/native/src/main/java/com/velocitypowered/natives/compression/Java11VelocityCompressor.java
+++ b/native/src/main/java/com/velocitypowered/natives/compression/Java11VelocityCompressor.java
@@ -80,6 +80,9 @@ public class Java11VelocityCompressor implements VelocityCompressor {
 
       inflater.reset();
     } catch (Throwable e) {
+      if (e instanceof DataFormatException) {
+        throw (DataFormatException) e;
+      }
       throw new RuntimeException(e);
     }
   }
@@ -111,6 +114,9 @@ public class Java11VelocityCompressor implements VelocityCompressor {
 
       deflater.reset();
     } catch (Throwable e) {
+      if (e instanceof DataFormatException) {
+        throw (DataFormatException) e;
+      }
       throw new RuntimeException(e);
     }
   }