Simplify decoding logic

kafkaex · Jan 23, 2024 · 53d26fd · 53d26fd
1 parent 4aef47a
commit 53d26fd
Showing 1 changed file with 5 additions and 10 deletions.
diff --git a/lib/kayrock/message_set.ex b/lib/kayrock/message_set.ex
@@ -81,16 +81,11 @@ defmodule Kayrock.MessageSet do
           }
 
         c ->
-          decompressed = Kayrock.Compression.decompress(c, value)
-
-          if magic == 1 do
-            decompressed
-            |> do_deserialize([], 0)
-            |> correct_offsets(offset)
-            |> Enum.reverse()
-          else
-            Enum.reverse(do_deserialize(decompressed, [], 0))
-          end
+          c
+          |> Kayrock.Compression.decompress(value)
+          |> do_deserialize([], 0)
+          |> correct_offsets(offset)
+          |> Enum.reverse()
       end
 
     do_deserialize(orig_rest, [msg | acc], add_offset)