From dda6cf21d9d048555e1cf315ae4808db3f2452ab Mon Sep 17 00:00:00 2001
From: Matt Howlett <matt.howlett@gmail.com>
Date: Thu, 15 Aug 2019 15:53:30 -0700
Subject: [PATCH] Fix fetch request rkbuf size

---
 src/rdkafka_broker.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/rdkafka_broker.c b/src/rdkafka_broker.c
index 24cfc3ca83..5481678bf5 100644
--- a/src/rdkafka_broker.c
+++ b/src/rdkafka_broker.c
@@ -4088,8 +4088,8 @@ static int rd_kafka_broker_fetch_toppars (rd_kafka_broker_t *rkb, rd_ts_t now) {
 
 	rkbuf = rd_kafka_buf_new_request(
                 rkb, RD_KAFKAP_Fetch, 1,
-                /* ReplicaId+MaxWaitTime+MinBytes+TopicCnt */
-                4+4+4+4+
+                /* ReplicaId+MaxWaitTime+MinBytes+MaxBytes+IsolationLevel+TopicCnt */
+                4+4+4+4+1+4+
                 /* N x PartCnt+Partition+FetchOffset+MaxBytes+?TopicNameLen?*/
                 (rkb->rkb_active_toppar_cnt * (4+4+8+4+40)));