From aa838e15ff33b4f3546c0f68d9ddb8638fd637ee Mon Sep 17 00:00:00 2001 From: Dana Powers 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 (, ) + ((1, 0, 0), MetadataRequest[5]), ((0, 11, 0), MetadataRequest[4]), ((0, 10, 2), OffsetFetchRequest[2]), ((0, 10, 1), MetadataRequest[2]), -- cgit v1.2.1