diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-05-03 17:35:59 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-05-03 17:35:59 -0700 |
| commit | d401bde9ed64d5d50b7ecd1f6bdf3f3c664bb075 (patch) | |
| tree | acd149c57c7fcb59c7f25a19aa455840749ae973 /kafka/consumer/group.py | |
| parent | 874f4874a7a126c27abff5e436e79602ef0983f9 (diff) | |
| parent | a3b7dca1b03e8d8d1e1e6c9339a5e12ccb5f51ea (diff) | |
| download | kafka-python-d401bde9ed64d5d50b7ecd1f6bdf3f3c664bb075.tar.gz | |
Merge pull request #678 from dpkp/check_version_0_10
Add protocol support for ApiVersionRequest
Diffstat (limited to 'kafka/consumer/group.py')
| -rw-r--r-- | kafka/consumer/group.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index abb65ef..eaaafa4 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -225,7 +225,7 @@ class KafkaConsumer(six.Iterator): # Check Broker Version if not set explicitly if self.config['api_version'] == 'auto': self.config['api_version'] = self._client.check_version() - assert self.config['api_version'] in ('0.9', '0.8.2', '0.8.1', '0.8.0'), 'Unrecognized api version' + assert self.config['api_version'] in ('0.10', '0.9', '0.8.2', '0.8.1', '0.8.0'), 'Unrecognized api version' # Convert api_version config to tuple for easy comparisons self.config['api_version'] = tuple( |