Pykafka

Latest version: v2.8.0

Safety actively analyzes 685670 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 6 of 6

1.0.0

------------------

Features
********

Completely re-wrote almost everything and renamed to PyKafka.

0.3.8

------------------

Features
********

- `Topic.latest_offsets` and `Partition.latest_offset` convenience functions

- Test cases are now significantly faster, but still deadlocking in Travis-CI

Bug Handling
************

- Issue 93: deal with case where kazoo is passed in not-connected

- Issue 91: offsets can get corrupted

- Handle race condition where zookeeper gave None for broker information
after it had been removed

- Pin kazoo to v1.1 because 1.2 is broken in PYPI

0.3.6

------------------

Features
********

- Improved partition queueing. Won't wait when there are partitions with data.

- Production-ready rebalancing. Refactoring and bug fixing resulting in greater
stability when adding and removing consumers and eliminated known race
conditions.

Bug Handling
************

- Issue 80: `decode_messages` crashes when payload ends in a header

- Issue 79: unexpected "Couldn't acquire partitions error"

- Issue 78: unexpected "sample larger than population" error

- Issue 77: prevent integration tests from starting before zookeeper cluster
and kafka broker are ready

- Issue 76: test for "more workers than queues" in partitioner

- Issue 68: All watches should use the DataWatch recipe

- Issue 62: Dead lock when consumer timeout is None and no messages

Page 6 of 6

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.