openstack/deb-python-kafka
Code Issues Proposed changes

Fixup SimpleClient.topic_partitions comment

Browse Source
This commit is contained in:
Dana Powers
2016-02-15 16:13:30 -08:00
parent 7eeba0d15f
commit 494800cd00
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/client.py
View File

@@ -48,7 +48,7 @@ class SimpleClient(object):
self._conns = {}
self.brokers = {} # broker_id -> BrokerMetadata
self.topics_to_brokers = {} # TopicPartition -> BrokerMetadata
self.topic_partitions = {} # topic -> partition -> PartitionMetadata
self.topic_partitions = {} # topic -> partition -> leader
self.load_metadata_for_topics() # bootstrap with all metadata