diff options
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 |