diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-09 16:52:01 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-10 12:06:04 -0800 |
| commit | 9837927c70abd3e032a9aefbd2990a7605276670 (patch) | |
| tree | 901fc7033d4f2d17b1ac7dbaec92f8a48aa31aed /kafka/coordinator | |
| parent | 814b599c49a0e5fafc1e2598731e582aac5b380f (diff) | |
| download | kafka-python-9837927c70abd3e032a9aefbd2990a7605276670.tar.gz | |
KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync
Diffstat (limited to 'kafka/coordinator')
| -rw-r--r-- | kafka/coordinator/consumer.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 9828252..7390ab3 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -146,7 +146,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 |