From fa60830e543972665f482db438362aefc84f74db Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Fri, 24 May 2019 00:23:31 -0700 Subject: Remove deprecated `'smallest'`/`'largest'` These have been deprecated in favor of `'earliest'` and `'latest'` for a while. --- kafka/consumer/group.py | 7 ------- 1 file changed, 7 deletions(-) (limited to 'kafka') diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index d504c09..888cfbf 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -315,13 +315,6 @@ class KafkaConsumer(six.Iterator): self.config = copy.copy(self.DEFAULT_CONFIG) self.config.update(configs) - deprecated = {'smallest': 'earliest', 'largest': 'latest'} - if self.config['auto_offset_reset'] in deprecated: - new_config = deprecated[self.config['auto_offset_reset']] - log.warning('use auto_offset_reset=%s (%s is deprecated)', - new_config, self.config['auto_offset_reset']) - self.config['auto_offset_reset'] = new_config - connections_max_idle_ms = self.config['connections_max_idle_ms'] request_timeout_ms = self.config['request_timeout_ms'] fetch_max_wait_ms = self.config['fetch_max_wait_ms'] -- cgit v1.2.1