Specify headers type on fetch protocol

kafkaex · May 31, 2021 · 91e9626 · 91e9626
1 parent 2637b4a
commit 91e9626
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafka_ex/protocol/fetch.ex b/lib/kafka_ex/protocol/fetch.ex
@@ -67,7 +67,7 @@ defmodule KafkaEx.Protocol.Fetch do
             offset: integer,
             key: binary,
             value: binary,
-            headers: list(),
+            headers: [{key::binary, value::binary}],
             topic: binary,
             partition: integer,
             # timestamp supported for `kafka_version: "kayrock"` ONLY