diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-05 17:35:44 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-05 17:35:44 -0800 |
| commit | aa838e15ff33b4f3546c0f68d9ddb8638fd637ee (patch) | |
| tree | f63ee51d9362cd42d756378b442018bf461de742 /kafka/conn.py | |
| parent | 441aeb864519d2f574650e24a327423308adca03 (diff) | |
| download | kafka-python-protocol_1_0_0.tar.gz | |
Add Request/Response structs for kafka broker 1.0.0protocol_1_0_0
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 1 |
1 files changed, 1 insertions, 0 deletions
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]), |