Aiokafka

Latest version: v0.10.0

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

Scan your dependencies

Page 4 of 5

0.2.2

Not secure
==================

* Reconnect after KafkaTimeoutException. (PR 149 by Artimi)
* Fixed compacted topic handling. It could skip messages if those were
compacted (issue 71)
* Fixed old issue with new topics not adding to subscription on pattern
(issue 46)
* Another fix for Consumer race condition on JoinGroup. This forces Leader to
wait for new metadata before assigning partitions. (issue 118)
* Changed metadata listener in Coordinator to avoid 2 rejoins in a rare
condition (issue 108)
* `getmany` will not return 0 results until we hit timeout. (issue 117)

Big thanks to Artimi for pointing out several of those issues.

0.2.1

Not secure
==================

* Add a check to wait topic autocreation in Consumer, instead of raising
UnknownTopicOrPartitionError (PR 92 by fabregas)
* Consumer now stops consumption after `consumer.stop()` call. Any new `get*` calls
will result in ConsumerStoppedError (PR 81)
* Added `exclude_internal_topics` option for Consumer (PR 111)
* Better support for pattern subscription when used with `group_id` (part of PR 111)
* Fix for Consumer `subscribe` and JoinGroup race condition (issue 88). Coordinator will now notice subscription changes during rebalance and will join group again. (PR 106)
* Changed logging messages according to KAFKA-3318. Now INFO level should be less messy and more informative. (PR 110)
* Add support for connections_max_idle_ms config (PR 113)

0.2.0

Not secure
==================

* Added SSL support. (PR 81 by Drizzt1991)
* Fixed UnknownTopicOrPartitionError error on first message for autocreated topic (PR 96 by fabregas)
* Fixed `next_record` recursion (PR 94 by fabregas)
* Fixed Heartbeat fail if no consumers (PR 92 by fabregas)
* Added docs addressing kafka-python and aiokafka differences (PR 70 by Drizzt1991)
* Added `max_poll_records` option for Consumer (PR 72 by Drizzt1991)
* Fix kafka-python typos in docs (PR 69 by jeffwidman)
* Topics and partitions are now randomized on each Fetch request (PR 66 by Drizzt1991)

0.1.4

Not secure
==================

* Bumped kafka-python version to 1.3.1 and Kafka to 0.10.1.0.
* Fixed auto version detection, to correctly handle 0.10.0.0 version
* Updated Fetch and Produce requests to use v2 with v0.10.0 message format on brokers.
This allows a ``timestamp`` to be associated with messages.
* Changed lz4 compression framing, as it was changed due to KIP-57 in new message format.
* Minor refactorings

Big thanks to fabregas for the hard work on this release (PR 60)

0.1.3

Not secure
==================

* Fixed bug with infinite loop on heartbeats with autocommit=True. 44
* Bumped kafka-python to version 1.1.1
* Fixed docker test runner with multiple interfaces
* Minor documentation fixes

0.1.2

Not secure
==================

* Added Python3.5 usage example to docs
* Don't raise retriable exceptions in 3.5's async for iterator
* Fix Cancellation issue with producer's `send_and_wait` method

Page 4 of 5

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.