diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2018-11-17 02:56:55 -0800 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2018-11-18 00:22:52 -0800 |
| commit | d67157cb9a032a6f0493cea128bbcd0528f3e640 (patch) | |
| tree | 8702c32b07cd8394ba036caa4afaeb4058f0b755 | |
| parent | 1d443638e22c2d360086b8d7cee8b5d930741d12 (diff) | |
| download | kafka-python-d67157cb9a032a6f0493cea128bbcd0528f3e640.tar.gz | |
Remove support for api versions as strings from KafkaAdmin
This is a new class, so let's not support the old version strings and
saddle ourselves with tech debt right from the get-go.
| -rw-r--r-- | kafka/admin/kafka.py | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/kafka/admin/kafka.py b/kafka/admin/kafka.py index 7aceea1..5ce8630 100644 --- a/kafka/admin/kafka.py +++ b/kafka/admin/kafka.py @@ -174,16 +174,6 @@ class KafkaAdmin(object): self.config = copy.copy(self.DEFAULT_CONFIG) self.config.update(configs) - # api_version was previously a str. accept old format for now - if isinstance(self.config['api_version'], str): - deprecated = self.config['api_version'] - if deprecated == 'auto': - self.config['api_version'] = None - else: - self.config['api_version'] = tuple(map(int, deprecated.split('.'))) - log.warning('use api_version=%s [tuple] -- "%s" as str is deprecated', - str(self.config['api_version']), deprecated) - # Configure metrics metrics_tags = {'client-id': self.config['client_id']} metric_config = MetricConfig(samples=self.config['metrics_num_samples'], |