diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-05-02 20:59:05 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-05-02 20:59:05 -0700 |
| commit | a3b7dca1b03e8d8d1e1e6c9339a5e12ccb5f51ea (patch) | |
| tree | acd149c57c7fcb59c7f25a19aa455840749ae973 /kafka/conn.py | |
| parent | 874f4874a7a126c27abff5e436e79602ef0983f9 (diff) | |
| download | kafka-python-a3b7dca1b03e8d8d1e1e6c9339a5e12ccb5f51ea.tar.gz | |
Add protocol support for ApiVersionRequest; identify 0.10 brokers in check_versioncheck_version_0_10
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 b5c7ba0..6c44aaf 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -520,7 +520,7 @@ class BrokerConnection(object): # vanilla MetadataRequest. If the server did not recognize the first # request, both will be failed with a ConnectionError that wraps # socket.error (32, 54, or 104) - from .protocol.admin import ListGroupsRequest + from .protocol.admin import ApiVersionRequest, ListGroupsRequest from .protocol.commit import OffsetFetchRequest, GroupCoordinatorRequest from .protocol.metadata import MetadataRequest @@ -536,6 +536,7 @@ class BrokerConnection(object): log.addFilter(log_filter) test_cases = [ + ('0.10', ApiVersionRequest[0]()), ('0.9', ListGroupsRequest[0]()), ('0.8.2', GroupCoordinatorRequest[0]('kafka-python-default-group')), ('0.8.1', OffsetFetchRequest[0]('kafka-python-default-group', [])), |