From aa838e15ff33b4f3546c0f68d9ddb8638fd637ee Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@gmail.com>
Date: Mon, 5 Feb 2018 17:35:44 -0800
Subject: Add Request/Response structs for kafka broker 1.0.0

---
 kafka/conn.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'kafka/conn.py')

diff --git a/kafka/conn.py b/kafka/conn.py
index 5ff27d5..4fe5e21 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -818,6 +818,7 @@ class BrokerConnection(object):
         # in reverse order. As soon as we find one that works, return it
         test_cases = [
             # format (<broker version>, <needed struct>)
+            ((1, 0, 0), MetadataRequest[5]),
             ((0, 11, 0), MetadataRequest[4]),
             ((0, 10, 2), OffsetFetchRequest[2]),
             ((0, 10, 1), MetadataRequest[2]),
-- 
cgit v1.2.1