summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Sibiryakov <sibiryakov@users.noreply.github.com>2016-12-28 00:38:52 +0100
committerDana Powers <dana.powers@gmail.com>2016-12-27 15:38:52 -0800
commit2e80fbb0c25f1aaea12a6dc746e93f19fe7d2757 (patch)
tree660cd7447ae4893a98d1a759f044be5387d7fe48
parent4acb7f443464542d08753163d47c16b6b4a5a4a5 (diff)
downloadkafka-python-2e80fbb0c25f1aaea12a6dc746e93f19fe7d2757.tar.gz
Fix of exception raise in case of auto_offset_reset is set to None in KafkaConsumer (#860)
-rw-r--r--kafka/consumer/fetcher.py4
1 files 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)