kazoo
kazoo copied to clipboard
Kazoo is a high-level Python library that makes it easier to use Apache Zookeeper.
Summary: Kazoo appears to be supplying "from_config"/"config_version" incorrectly in the `reconfig` command. ## Expected Behavior 1. `get('/zookeeper/config')` yields a config with a version. 2. `reconfig(joining"some hosts", leaving=None, new_hosts=None, from_config=version)`, where...
The lock recipe assumes `threading.Lock.acquire()` does **not** take a timeout argument. https://github.com/python-zk/kazoo/blob/b20c929421ff72421ad3770fb3436d583df5e5b0/kazoo/recipe/lock.py#L173 https://docs.python.org/3/library/threading.html#threading.Lock.acquire > Changed in version 3.2: The timeout parameter is new. Code can be simplified a lot now...
We are in the process of upgrading ZooKeeper from 3.4.6 to 3.6.1. Upon doing so, kazoo.client.KazooClient().server_version() now throws an exception when connected to a zookeeper instance running zookeeper-3.6.1. This previously...
I have an issue where Kazoo client timesout. I'm using Kazoo through a library called pysolr. Here's a link to the source code line number: https://github.com/django-haystack/pysolr/blob/cbb68d3905cf2aa7dc9b3100dd9ec959e10add18/pysolr.py#L1509 I am using default...
The [release notes for 2.8.0](https://github.com/python-zk/kazoo/releases/tag/2.8.0) seem to indicate that Python 3.6 is no longer supported: > __PYTHON SUPPORTED VERSIONS CHANGE__: Please note that Kazoo no longer tests > on Python...
Currently there is no option to enable SSL hostname verification.
https://github.com/python-zk/kazoo/blob/b20c929421ff72421ad3770fb3436d583df5e5b0/kazoo/recipe/lock.py#L286 This assumption badly broken. Sequence numbers are **signed** 32bit wrapping numbers. https://zookeeper.apache.org/doc/r3.6.0/zookeeperProgrammers.html#Sequence+Nodes+--+Unique+Naming The proper way to handle them is to use [SNA](https://en.wikipedia.org/wiki/Serial_number_arithmetic)
I am facing issue with kazoo while implementing lock with default_acl. When I initialize client and try to create node, it shows, NoAuthError. I m sharing the code below. `credentials=make_digest_acl_credential('distribution','password')...
from kazoo.client import KazooClient from kazoo.exceptions import NodeExistsError,ConnectionLoss from kazoo.security import ACL, OPEN_ACL_UNSAFE from kazoo.handlers.gevent import SequentialGeventHandler from kazoo.handlers.threading import SequentialThreadingHandler client = KazooClient(hosts='127.0.0.1:2181', handler=SequentialGeventHandler()) client.start_async() while True: gevent.sleep(1) print(client.state,...
When using SASL authentication, if a kazoo client is disconnected, all future API calls will return NoAuthError on reconnect. The issue appears to be that the connection object maintains the...