From 02b9798d23d3566fd8298a4d978d6620489ba263 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Sat, 17 Nov 2018 02:56:55 -0800 Subject: 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. --- kafka/admin/kafka.py | 10 ---------- 1 file changed, 10 deletions(-) (limited to 'kafka/admin/kafka.py') diff --git a/kafka/admin/kafka.py b/kafka/admin/kafka.py index fbbbcc2..eb3150e 100644 --- a/kafka/admin/kafka.py +++ b/kafka/admin/kafka.py @@ -171,16 +171,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'], -- cgit v1.2.1