confluent-kafka-python v2.0.2
v2.0.2 is a feature release with the following features, fixes and enhancements:
- Added Python 3.11 wheels.
- KIP-222 Add Consumer Group operations to Admin API.
- KIP-518 Allow listing consumer groups per state.
- KIP-396 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 andcommit()
(#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
andAvroConsumer
. UseAvroSerializer
andAvroDeserializer
instead. - Deprecated
list_groups
. Uselist_consumer_groups
anddescribe_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 v2.0.2, see the
librdkafka v2.0.0 release notes
and later ones for a complete list of changes, enhancements, fixes and upgrade considerations.
Note: There were no v2.0.0 and v2.0.1 releases.