diff --git a/lib/logstash/inputs/kinesis/worker.rb b/lib/logstash/inputs/kinesis/worker.rb
index 3274a73..910bd9b 100644
--- a/lib/logstash/inputs/kinesis/worker.rb
+++ b/lib/logstash/inputs/kinesis/worker.rb
@@ -45,7 +45,10 @@ def checkpoint(checkpointer)
   end
 
   def process_record(record)
-    raw = @decoder.decode(record.getData).to_s
+    #raw = @decoder.decode(record.getData).to_s
+    is = com.fasterxml.jackson.databind.util::ByteBufferBackedInputStream.new(record.getData)
+    gzip = Java::java.util.zip::GZIPInputStream.new(is)
+    raw = gzip.to_io.read
     @codec.decode(raw) do |event|
       @decorator.call(event)
       @output_queue << event