diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-08-12 12:31:55 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-08-12 12:31:55 -0700 |
| commit | b45c99e14922f9fed7e20de62eb5eb1b67e42bc4 (patch) | |
| tree | 8f54998c67bd440681d502480ad9c7730b1501e8 | |
| parent | a624d53b78eeed34957925d9efd30322843afa2f (diff) | |
| download | kafka-python-initial_metadata_snapshot.tar.gz | |
Use subscription arg, not self._subscriptioninitial_metadata_snapshot
| -rw-r--r-- | kafka/coordinator/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 34b9cc0..123699f 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -164,7 +164,7 @@ class ConsumerCoordinator(BaseCoordinator): def _build_metadata_snapshot(self, subscription, cluster): metadata_snapshot = {} - for topic in self._subscription.group_subscription(): + for topic in subscription.group_subscription(): partitions = cluster.partitions_for_topic(topic) or [] metadata_snapshot[topic] = set(partitions) return metadata_snapshot |