diff options
author | Dana Powers <dana.powers@rd.io> | 2014-09-01 02:13:00 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2014-09-01 18:02:41 -0700 |
commit | 4da01fc3cee3b4b345eb31c7db017bfaab3a0776 (patch) | |
tree | 280eefb2dab69b0d3522a71c2ac25e6351e95fbd /kafka/client.py | |
parent | 18ac14860791db2382c3e62715f11a6f657f265a (diff) | |
download | kafka-python-4da01fc3cee3b4b345eb31c7db017bfaab3a0776.tar.gz |
Rearrange KafkaClient method order to group client metadata methods together
Diffstat (limited to 'kafka/client.py')
-rw-r--r-- | kafka/client.py | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/kafka/client.py b/kafka/client.py index e14694f..630e176 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -200,6 +200,24 @@ class KafkaClient(object): ################# # Public API # ################# + def close(self): + for conn in self.conns.values(): + conn.close() + + def copy(self): + """ + Create an inactive copy of the client object + A reinit() has to be done on the copy before it can be used again + """ + c = copy.deepcopy(self) + for k, v in c.conns.items(): + c.conns[k] = v.copy() + return c + + def reinit(self): + for conn in self.conns.values(): + conn.reinit() + def reset_topic_metadata(self, *topics): for topic in topics: try: @@ -229,24 +247,6 @@ class KafkaClient(object): self.load_metadata_for_topics(topic) time.sleep(.5) - def close(self): - for conn in self.conns.values(): - conn.close() - - def copy(self): - """ - Create an inactive copy of the client object - A reinit() has to be done on the copy before it can be used again - """ - c = copy.deepcopy(self) - for k, v in c.conns.items(): - c.conns[k] = v.copy() - return c - - def reinit(self): - for conn in self.conns.values(): - conn.reinit() - def load_metadata_for_topics(self, *topics): """ Discover brokers and metadata for a set of topics. This function is called |