Releases: aio-libs/aiokafka
Releases · aio-libs/aiokafka
v0.11.0
New features:
Bugfixes:
- Fix serialization for batch (issue #886, pr #887 by @ydjin0602)
- Fix type annotation for
AIOKafkaAdminClient.create_partitions
(pr #978 by @alm0ra) - Fix
NotControllerError
inAIOKafkaAdminClient.create_topics
and other
methods (issue #995) - Fix unintended cancellation of fetcher task (issue #983, pr #1007 by @apmorton)
v0.10.0
New features:
- Support static membership protocol, KIP-345 (issue #680, pr #941 by
@patkivikram and @joshuaherrera)
Bugfixes:
- Fix extra dependencies (issue #952)
v0.10.0.a0
New features:
- Support static membership protocol, KIP-345 (issue #680, pr #941 by
@patkivikram and @joshuaherrera)
v0.9.0
New features:
- Include
kafka-python
intoaiokafka
's code base (issue #928 and others) - Replace
python-snappy
andzstandard
withcramjam
(issue #930) - PEP518 compliant
pyproject.toml
- Python 3.12 support
Bugfixes:
- Fix type annotation for
ConsumerRecord
(pr #912 by @zschumacher) - Improve send performance (issue #943)
Improved Documentation:
v0.9.0.rc1
New features:
- Include
kafka-python
intoaiokafka
's code base - Replace
python-snappy
andzstandard
withcramjam
- PEP518 compliant
pyproject.toml
- Python 3.12 support
Bugfixes:
- Fix type annotation for
ConsumerRecord
(pr #912 by @zschumacher) - Improve send performance (issue #943)
Improved Documentation:
v0.9.0.rc0
New features:
- Include
kafka-python
intoaiokafka
's code base - Replace
python-snappy
andzstandard
withcramjam
- PEP518 compliant
pyproject.toml
- Python 3.12 support
Bugfixes:
- Fix type annotation for
ConsumerRecord
(pr #912 by @zschumacher)
Improved Documentation:
v0.8.1
v0.8.0
New features:
- Add codec for ZStandard compression (KIP-110) (pr #801)
- Add basic admin client functionality (pr #811 started by @gabriel-tincu)
- Drop support for Python 3.6, add support and pre-built packages for Python
3.10 (pr #841)
Bugfixes:
- Fix
KeyError
on solitary abort marker (issue #781, pr #782 by @pikulmar) - Fix handling unsupported compression codec (issue #795)
- Handled other SASL mechanism in logging (issue #852, pr #861 by @mangin)
Improved Documentation:
Bugfix release
Bugfixes:
- Fix
CancelledError
handling in sender (issue #710) - Fix exception for weakref use after object deletion (issue #755)
- Fix consumer's
start()
method hanging after being idle for more than
max_poll_interval_ms
(issue #764)
Improved Documentation:
- Add
SASL_PLAINTEXT
andSASL_SSL
to valid values of security protocol
attribute (pr #768 by @pawelrubin)
Bugfix release
Bugfixes:
- Allow group coordinator to close when all brokers are unavailable (issue #659
and pr #660 by @dkilgore90) - Exclude
.so
from source distribution to fix usage of sdist tarball
(issue #681 and pr #684 by ods) - Add
dataclasses
backport package to dependencies for Python 3.6
(pr #690 by @ods) - Fix initialization without running loop (issue #689 and pr #690 by @ods)
- Fix consumer fetcher for python3.9 (pr #672 by @dutradda)
- Make sure generation and member id are correct after (re)joining group.
(issue #727 and pr #747 by @vangheem)
Deprecation:
- Add deprecation warning when loop argument to AIOKafkaConsumer and
AIOKafkaProducer is passed. It's scheduled for removal in 0.8.0 as a
preparation step towards upcoming Python 3.10 (pr #699 by @ods)
Improved Documentation:
- Update docs and examples to not use deprecated practices like passing loop
explicitly (pr #693 by @ods) - Add docstring for Kafka header support in
Producer.send()
(issue #566 and
pr #650 by @andreportela)