diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:08:56 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-03 16:08:56 -0800 |
| commit | 16c56235d2fa1a9b63a38bd01aeb28be9aaa2405 (patch) | |
| tree | e9e3a8b9bcf6014f4822f9a8ec6f7bb3751e4288 | |
| parent | 2b43ae1609295e33f35aa4f5d1b61d60889b420c (diff) | |
| download | kafka-python-16c56235d2fa1a9b63a38bd01aeb28be9aaa2405.tar.gz | |
Keep support for old largest/smallest auto_offset_reset options
| -rw-r--r-- | kafka/consumer/group.py | 7 |
1 files changed, 7 insertions, 0 deletions
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 |