chore: fix gzip inflate to handle nested lists

kafkaex · Jul 5, 2024 · d98d177 · d98d177
1 parent ddb968b
commit d98d177
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/kayrock/compression.ex b/lib/kayrock/compression.ex
@@ -33,8 +33,8 @@ defmodule Kayrock.Compression do
   def decompress(@gzip_attribute, <<window_size::8-signed, _::bits>> = data) do
     z = :zlib.open()
     :zlib.inflateInit(z, window_size)
-    [v | _] = :zlib.inflate(z, data)
-    v
+    v = :zlib.inflate(z, data)
+    Enum.into(List.flatten(v), <<>>)
   end
 
   def decompress(@snappy_attribute, data) do