diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 17 |
1 files changed, 1 insertions, 16 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index 857e4b7..ff9730e 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -121,8 +121,7 @@ class KafkaClient(object): default: none. api_version (tuple): Specify which Kafka API version to use. If set to None, KafkaClient will attempt to infer the broker version by - probing various APIs. For the full list of supported versions, - see KafkaClient.API_VERSIONS. Default: None + probing various APIs. Example: (0, 10, 2). Default: None api_version_auto_timeout_ms (int): number of milliseconds to throw a timeout exception from the constructor when checking the broker api version. Only applies if api_version is None @@ -176,15 +175,6 @@ class KafkaClient(object): 'sasl_plain_password': None, 'sasl_kerberos_service_name': 'kafka', } - API_VERSIONS = [ - (0, 10, 1), - (0, 10, 0), - (0, 10), - (0, 9), - (0, 8, 2), - (0, 8, 1), - (0, 8, 0) - ] def __init__(self, **configs): self.config = copy.copy(self.DEFAULT_CONFIG) @@ -192,11 +182,6 @@ class KafkaClient(object): if key in configs: self.config[key] = configs[key] - if self.config['api_version'] is not None: - assert self.config['api_version'] in self.API_VERSIONS, ( - 'api_version [{0}] must be one of: {1}'.format( - self.config['api_version'], str(self.API_VERSIONS))) - self.cluster = ClusterMetadata(**self.config) self._topics = set() # empty set will fetch all topic metadata self._metadata_refresh_in_progress = False |