summaryrefslogtreecommitdiff
path: root/kafka/consumer/fetcher.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2019-12-29 16:06:24 -0800
committerGitHub <noreply@github.com>2019-12-29 16:06:24 -0800
commit2a86b23f477e5ed57aa987db97d11284a37d05a0 (patch)
tree391d4d2d99db38eb2f9869d76592851bbae57cf2 /kafka/consumer/fetcher.py
parent1a91a54688cb77fd77c342e719f24f346d5cee89 (diff)
downloadkafka-python-2a86b23f477e5ed57aa987db97d11284a37d05a0.tar.gz
Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)
Diffstat (limited to 'kafka/consumer/fetcher.py')
-rw-r--r--kafka/consumer/fetcher.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/consumer/fetcher.py b/kafka/consumer/fetcher.py
index f9d96b0..5cb25f2 100644
--- a/kafka/consumer/fetcher.py
+++ b/kafka/consumer/fetcher.py
@@ -185,7 +185,7 @@ class Fetcher(six.Iterator):
self._subscriptions.need_offset_reset(tp)
self._reset_offset(tp)
else:
- committed = self._subscriptions.assignment[tp].committed
+ committed = self._subscriptions.assignment[tp].committed.offset
log.debug("Resetting offset for partition %s to the committed"
" offset %s", tp, committed)
self._subscriptions.seek(tp, committed)