kazoo
kazoo copied to clipboard
python-zk
Kazoo is a high-level Python library that makes it easier to use Apache Zookeeper.
## Why is this needed? - bump the version - update changelog - backport the fix that overrides the `egg_info` `tag-build` configuration ## Proposed Changes - bump version to 2.9.0...
``` apache-storm-1.0.2 hbase-1.2.1 kafka_2.10-0.10.0.0 zookeeper-3.4.9 python 3.5.2 pykafka==2.5.0 kazoo==2.2.1 ``` **ops**: ``` zkServer.sh start $KAFKA_HOME/bin/kafka-server-start.sh $KAFKA_HOME/config/server.properties &! $KAFKA_HOME/bin/kafka-topics.sh --zookeeper localhost:2181 --create --replication-factor 1 --partitions 4 --topic trivver $KAFKA_HOME/bin/kafka-topics.sh --zookeeper localhost:2181...
Hi, I need an zookeeper protocol implementation for asyncio. While it seems kazoo supports different asynchronous APIs it relies on python stack in a way that doesn't allow integration with...
I implements my listener as follows: def my_listener(state): global zk global child_path global child_value ``` if state == KazooState.LOST: logger.warn("lost connection to zookeeper server") elif state == KazooState.SUSPENDED: logger.warn("connection has...
In my main thread I try to set up a DataWatch and a ChildrenWatch as follows. I have not put all the args since this is just to demonstrate the...
Make sure the number of attempts matches the `max_retry` parameter. Add unit tests to that effect. ## Why is this needed? So that users can precisely control the number of...
Fixes #724 No handlers could be found for logger "kazoo.handlers.threading" for better logging control, just like kazoo.client does
No handlers could be found for logger "kazoo.handlers.threading" after using logging.basicConfig(), it turns out ``` [2023-07-13 11:27:22,005] [ERROR] [3722:139833607571200] [threading.py:L130] Exception in worker queue thread Traceback (most recent call last):...
A bit about our setup for context: We use znodes as representation of work items (typically there are hundreds of work items / znodes present), and we have many workers...
## Expected Behavior According to Kazoo's documentation, after DataWatch returns False, the registered listener will be destroyed. Not only will Kazoo no longer trigger this listener, but when using wchp...
