v2.13.0b1 - 2025-11-25
This is a beta release intended for --pre installers to get early access to upcoming changes. Exact changes included are:
- Enforced type hinting for all interfaces
- Handle OAuth Token Refreshes
- Added black and isort linting rules and enforcement to codebase
- Fix support for wrapped Avro unions
- Enabled direct creation of Message objects
- Added
close()method to producer - Added context manager for librdkafka classes to enable easy scope cleanup
- Fixed segfault exceptions on calls against objects that had closed internal objects
- Handle evolution during field transformation of schemas
- Expose deterministic partitioner functions
- Handle null group name to prevent segfault in Admin
list_consumer_group_offsets() - Add Accept-Version header for schemas
- Ensure schemaId initialization is thread-safe
- Fix error propagation rule for Python's C API
- Fix SR delete behavior with client-side caching
- Enhanced the BufferTimeoutManager to flush the librdkafka queue