diff options
| author | Lourens Naudé <lourens@methodmissing.com> | 2020-11-15 19:50:46 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-11-15 11:50:46 -0800 |
| commit | 8b8a48ba09677e38088c61ade2dab2e42198ab3f (patch) | |
| tree | a213ec3a9fd14df47965daa690f05246be1b451d /kafka/conn.py | |
| parent | 6c87155bbd855f6bba1ba30b2b6227e66ea79baa (diff) | |
| download | kafka-python-8b8a48ba09677e38088c61ade2dab2e42198ab3f.tar.gz | |
Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162)
* Co-authored-by: Andrew Brown <andrew.brown@shopify.com>
* Co-authored-by: Aaron Brady <aaron.brady@shopify.com>
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index 5c72875..cac3548 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -24,7 +24,7 @@ import kafka.errors as Errors from kafka.future import Future from kafka.metrics.stats import Avg, Count, Max, Rate from kafka.oauth.abstract import AbstractTokenProvider -from kafka.protocol.admin import SaslHandShakeRequest, DescribeAclsRequest_v2 +from kafka.protocol.admin import SaslHandShakeRequest, DescribeAclsRequest_v2, DescribeClientQuotasRequest from kafka.protocol.commit import OffsetFetchRequest from kafka.protocol.offset import OffsetRequest from kafka.protocol.produce import ProduceRequest @@ -1169,6 +1169,7 @@ class BrokerConnection(object): # in reverse order. As soon as we find one that works, return it test_cases = [ # format (<broker version>, <needed struct>) + ((2, 6, 0), DescribeClientQuotasRequest[0]), ((2, 5, 0), DescribeAclsRequest_v2), ((2, 4, 0), ProduceRequest[8]), ((2, 3, 0), FetchRequest[11]), |