Fixup SimpleClient.topic_partitions comment

dpkp · dpkp · commit 494800cd004b · 2016-02-15T16:13:30.000-08:00
diff --git a/kafka/client.py b/kafka/client.py
@@ -48,7 +48,7 @@ def __init__(self, hosts, client_id=CLIENT_ID,
         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
 
