summaryrefslogtreecommitdiff
path: root/kafka/client.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-09-01 02:13:00 -0700
committerDana Powers <dana.powers@rd.io>2014-09-01 18:02:41 -0700
commit4da01fc3cee3b4b345eb31c7db017bfaab3a0776 (patch)
tree280eefb2dab69b0d3522a71c2ac25e6351e95fbd /kafka/client.py
parent18ac14860791db2382c3e62715f11a6f657f265a (diff)
downloadkafka-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.py36
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