From 2e80fbb0c25f1aaea12a6dc746e93f19fe7d2757 Mon Sep 17 00:00:00 2001 From: Alexander Sibiryakov Date: Wed, 28 Dec 2016 00:38:52 +0100 Subject: [PATCH] Fix of exception raise in case of auto_offset_reset is set to None in KafkaConsumer (#860) --- kafka/consumer/fetcher.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py index 1cfebcb..00d26c6 100644 --- a/kafka/consumer/fetcher.py +++ b/kafka/consumer/fetcher.py @@ -747,12 +747,12 @@ class Fetcher(six.Iterator): self._client.cluster.request_update() elif error_type is Errors.OffsetOutOfRangeError: fetch_offset = fetch_offsets[tp] + log.info("Fetch offset %s is out of range for topic-partition %s", fetch_offset, tp) if self._subscriptions.has_default_offset_reset_policy(): self._subscriptions.need_offset_reset(tp) + log.info("Resetting offset for topic-partition %s", tp) else: self._offset_out_of_range_partitions[tp] = fetch_offset - log.info("Fetch offset %s is out of range, resetting offset", - fetch_offset) elif error_type is Errors.TopicAuthorizationFailedError: log.warn("Not authorized to read from topic %s.", tp.topic) self._unauthorized_topics.add(tp.topic)