From a94d8fa1cb670b65a4815a05cda6f774f555c632 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Sat, 9 Jan 2016 16:52:01 -0800 Subject: KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync --- kafka/coordinator/consumer.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'kafka/coordinator/consumer.py') diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 48d5e14..d728624 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -167,7 +167,8 @@ class ConsumerCoordinator(BaseCoordinator): old_partitions_per_topic = self._partitions_per_topic self._partitions_per_topic = {} for topic in self._subscription.group_subscription(): - self._partitions_per_topic[topic] = set(self._cluster.partitions_for_topic(topic)) + partitions = self._cluster.partitions_for_topic(topic) or [] + self._partitions_per_topic[topic] = set(partitions) if self._partitions_per_topic != old_partitions_per_topic: return True -- cgit v1.2.1