- Added Python 3.11 wheels.
- [KIP-222](https://cwiki.apache.org/confluence/display/KAFKA/KIP-222+-+Add+Consumer+Group+operations+to+Admin+API)
Add Consumer Group operations to Admin API.
- [KIP-518](https://cwiki.apache.org/confluence/display/KAFKA/KIP-518%3A+Allow+listing+consumer+groups+per+state)
Allow listing consumer groups per state.
- [KIP-396](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97551484)
Partially implemented: support for AlterConsumerGroupOffsets.
- As result of the above KIPs, added (1449)
- `list_consumer_groups` Admin operation. Supports listing by state.
- `describe_consumer_groups` Admin operation. Supports multiple groups.
- `delete_consumer_groups` Admin operation. Supports multiple groups.
- `list_consumer_group_offsets` Admin operation. Currently, only supports 1 group with multiple partitions. Supports require_stable option.
- `alter_consumer_group_offsets` Admin operation. Currently, only supports 1 group with multiple offsets.
- Added `normalize.schemas` configuration property to Schema Registry client (rayokota, 1406)
- Added metadata to `TopicPartition` type and `commit()` (1410).
- Added `consumer.memberid()` for getting member id assigned to
the consumer in a consumer group (1154).
- Implemented `nb_bool` method for the Producer, so that the default (which uses len)
will not be used. This avoids situations where producers with no enqueued items would
evaluate to False (vladz-sternum, 1445).
- Deprecated `AvroProducer` and `AvroConsumer`. Use `AvroSerializer` and `AvroDeserializer` instead.
- Deprecated `list_groups`. Use `list_consumer_groups` and `describe_consumer_groups` instead.
- Improved Consumer Example to show atleast once semantics.
- Improved Serialization and Deserialization Examples.
- Documentation Improvements.
Upgrade considerations
OpenSSL 3.0.x upgrade in librdkafka requires a major version bump, as some
legacy ciphers need to be explicitly configured to continue working,
but it is highly recommended NOT to use them. The rest of the API remains
backward compatible.
confluent-kafka-python is based on librdkafka 2.0.2, see the