diff 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 |