From b787a2211ec4bdda6f06d915f819e4d8c5607cd5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Stef=C3=A1n=20=C3=9Eorvar=C3=B0arson?= Date: Wed, 9 Mar 2016 11:50:29 +0000 Subject: Bug fix: KafkaConsumer.position() Method KafkaConsumer.position() was not refreshing position correctly when calling self._update_fetch_positions(). --- kafka/consumer/group.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index cf77df3..b43b0f4 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -477,7 +477,7 @@ class KafkaConsumer(six.Iterator): assert self._subscription.is_assigned(partition), 'Partition is not assigned' offset = self._subscription.assignment[partition].position if offset is None: - self._update_fetch_positions(partition) + self._update_fetch_positions([partition]) offset = self._subscription.assignment[partition].position return offset -- cgit v1.2.1