From 16c56235d2fa1a9b63a38bd01aeb28be9aaa2405 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sun, 3 Jan 2016 16:08:56 -0800 Subject: Keep support for old largest/smallest auto_offset_reset options --- kafka/consumer/group.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 44666ad..fe94d86 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -167,6 +167,13 @@ class KafkaConsumer(six.Iterator): # Only check for extra config keys in top-level class assert not configs, 'Unrecognized configs: %s' % 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 + self._client = KafkaClient(**self.config) # Check Broker Version if not set explicitly -- cgit v1.2.1