def connect(self):
self.client = client.KazooClient(hosts="<STR_LIT:U+002C>".join(self.hosts))<EOL>self.client.add_listener(self.handle_connection_change)<EOL>self.client.start_async()<EOL>
Creates a new KazooClient and establishes a connection.

Passes the client the `handle_connection_change` method as a callback
to fire when the Zookeeper connection changes state.