PyPI · #3582 most downloaded on PyPI

kafka-python-ng

2.2.31.3M downloads/mowbarnha/kafka-python-ng ↗New releases in your daily digest, changelog included.

Pure Python client for Apache Kafka

Release timeline

6 releases since 2024

202420252026

2.2.14 Apr 2024

Add connection_timeout_ms and reset the timeout counter more often by @petterroea in #132

Add connection_timeout_ms and reset the timeout counter more often by @petterroea in #132
add validate_config function for msk module by @Sharu95 in #176

Full Changelog: v2.2.0...v2.2.1

2.2.027 Mar 2024

Support Describe log dirs by @Courouge in #145

Support Describe log dirs by @Courouge in #145
Update conftest.py to use request.node.originalname instead for legal topic naming by @wbarnha in #172
KIP-345 Static membership implementation by @KazakovDenis in #137
Use monkeytype to create some semblance of typing by @wbarnha in #173
Add zstd support on legacy record and ensure no variable is referred before definition by @ax-ale in #138
Update init.py of SASL to catch ImportErrors in case botocore is not installed by @wbarnha in #175

Full Changelog: v2.1.0...v2.2.0

Additional notes

2.1.019 Mar 2024

Reconfigure tests to complete in a more timely manner and skip some iterations for Kafka 0.8.2 and Python 3.12 by @wbarnha in #159

Reconfigure tests to complete in a more timely manner and skip some iterations for Kafka 0.8.2 and Python 3.12 by @wbarnha in #159
Test Kafka 0.8.2.2 using Python 3.10 in the meantime by @wbarnha in #161
Remove support for EOL'ed versions of Python by @wbarnha in #160
Stop testing Python 3.13 in python-package.yml by @wbarnha in #162
Avoid 100% CPU usage while socket is closed by @orange-kao in #156
Fix DescribeConfigsResponse_v1 config_source vs is_default by @ryarnyah in #150
Fix base class of DescribeClientQuotasResponse_v0 by @ods in #144
Update license_file to license_files by @micwoj92 in #131
Update some RST documentation syntax by @HalfSweet in #130
Fix crc32c's main for Python 3 by @Jongy in #142
Strip trailing dot off hostname used for SSL validation. by @voutilad in #133
Handle OSError to properly recycle SSL connection, fix infinite loop by @sibiryakov in #155
client_async: Allow throwing an exception upon socket error during wakeup by @shimon-armis in #134
Log connection errors at ERROR level by @drewdogg in #139
Support custom SASL mechanisms including AWS MSK by @wbarnha and @mattoberle in #170
Use PyUpgrade for 3.8+ for updating project by @wbarnha in #171
Remove all vendoring by @s-t-e-v-e-n-k in #169

Full Changelog: v2.0.3...v2.1.0

2.0.37 Mar 2024

Rename project from kafka-python to kafka-python-ng by @wbarnha in #1

Full Changelog: https://github.com/wbarnha/kafka-python-ng/commits/v2.0.3

Additional notes2 sources agree

Consumer