diff --git core/src/test/scala/unit/kafka/message/CompressionUtilsTest.scala core/src/test/scala/unit/kafka/message/CompressionUtilsTest.scala
index df96603..7191c6e 100644
--- core/src/test/scala/unit/kafka/message/CompressionUtilsTest.scala
+++ core/src/test/scala/unit/kafka/message/CompressionUtilsTest.scala
@@ -17,6 +17,7 @@
 
 package kafka.message
 
+import java.io.ByteArrayOutputStream
 import kafka.utils.TestUtils
 import org.scalatest.junit.JUnitSuite
 import org.junit.Test
@@ -59,6 +60,8 @@ class CompressionUtilTest extends JUnitSuite {
 
   @Test
   def testSnappyCompressDecompressExplicit() {
+    if(!isSnappyAvailable())
+      return
 
     val messages = List[Message](new Message("hi there".getBytes), new Message("I am fine".getBytes), new Message("I am not so well today".getBytes))
 
@@ -72,4 +75,13 @@ class CompressionUtilTest extends JUnitSuite {
 
     TestUtils.checkEquals(messages.iterator, TestUtils.getMessageIterator(decompressedMessages.iterator))
   }
+
+  def isSnappyAvailable(): Boolean = {
+    try {
+      val snappy = new org.xerial.snappy.SnappyOutputStream(new ByteArrayOutputStream())
+      true
+    } catch {
+      case e: UnsatisfiedLinkError => false
+    }
+  }
 }