diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2019-05-24 00:23:31 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-05-24 00:25:47 -0700 |
| commit | fa60830e543972665f482db438362aefc84f74db (patch) | |
| tree | 82e6ec729707c64b85e625aa4a760df3f0dc4506 | |
| parent | cee4d17df7858439e0dbdf3914ca0107e080af7d (diff) | |
| download | kafka-python-Remove-deprecated-smallest-largest.tar.gz | |
Remove deprecated `'smallest'`/`'largest'`Remove-deprecated-smallest-largest
These have been deprecated in favor of `'earliest'` and `'latest'` for a
while.
| -rw-r--r-- | kafka/consumer/group.py | 7 |
1 files changed, 0 insertions, 7 deletions
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'] |