From 57a93c8990b7a4b59d47ec124507d93684f82718 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Rog=C3=A9rio=20Ramos?= <habutre+github@gmail.com>
Date: Wed, 4 Nov 2020 23:47:41 +0100
Subject: [PATCH] Specify headers type on fetch protocol

---
 lib/kafka_ex/protocol/fetch.ex | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/kafka_ex/protocol/fetch.ex b/lib/kafka_ex/protocol/fetch.ex
index a4a62977..27e19460 100644
--- 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