v2.13.2 is a maintenance release with the following fixes and enhancements:
Enhancements
- Add Confluent-Client-Version header to requests to SR, Python client (#2148)
- Add UAMI OAuth changes (#2189)
Fixes
- Fixed memory leak in Producer.produce() when called with headers and raises BufferError (queue full) or RuntimeError (producer closed). The allocated rd_headers memory is now properly freed in error paths before returning. Fixes Issue #2167.
- Fixed type hinting of KafkaError class, Consumer.init(), Producer.init(), Producer.produce() and Consumer.commit() and introduced a script in tools directory to keep error codes up to date. Fixes Issue #2168.
- Fix the token expiration logic in SR Oauth (#2177)
- Ensure use of cachetools is thread-safe (#2178)
- Remove passing resolver in json validate (#2186)
- Fix JSON schema resolver bug (#2188)
confluent-kafka-python v2.13.2 is based on librdkafka v2.13.2, see the librdkafka release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
Installation
pip install confluent-kafka==2.13.2