* Ensure algorithm query param is passed for CSFLE
* DGS-19492 Handle records nested in arrays/maps when searching
for tags
* confluent-kafka-python v2.8.0 is based on librdkafka v2.8.0,
see the librdkafka release notes
- update to 2.7.0:
* Support for Data Contracts with Schema Registry, including
+ Data Quality rules
+ Data Transformation rules
+ Client-Side Field Level Encryption (CSFLE)
+ Schema Migration rules (requires Python 3.9+)
* Migrated the Schema Registry client from requests to httpx
* Add support for multiple URLs
* Allow configuring timeout
* Fix deletion semantics
* Python deserializer can take SR client
* Fix handling of Avro unions
* Remove deprecated RefResolver for JSON
* Support delete of subject version
* Added missing dependency on googleapis-common-protos when
using protobufs.
- update to 2.6.2:
* Support for Data Contracts with Schema Registry, including
* Data Quality rules
* Data Transformation rules
* Client-Side Field Level Encryption (CSFLE)
* Schema Migration rules (requires Python 3.9+)
* Migrated the Schema Registry client from requests to httpx
* Add support for multiple URLs
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=19
- update to 2.3.0:
* Add Python 3.12 wheels
* KIP-117: Add support for AdminAPI `describe_cluster()` and
`describe_topics()`. (@jainruchir, #1635)
* KIP-430:
* Return authorized operations in Describe Responses.
(@jainruchir, #1635)
* KIP-516: Partial support of topic identifiers. Topic
identifiers in metadata response are available through the
new describe_topics function (#1645).
* KIP-396: completed the implementation with the addition of
`list_offsets` (#1576).
* Add `Rack` to the `Node` type, so AdminAPI calls can expose
racks for brokers
* Fix the Describe User Scram Credentials for Describe all
users or empty users list.
* confluent-kafka-python is based on librdkafka v2.3.0, see the
librdkafka release notes for a complete list of changes,
enhancements, fixes and upgrade considerations.
OBS-URL: https://build.opensuse.org/request/show/1130506
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-confluent-kafka?expand=0&rev=8
* Add Python 3.12 wheels
* KIP-117: Add support for AdminAPI `describe_cluster()` and
`describe_topics()`. (@jainruchir, #1635)
* KIP-430:
* Return authorized operations in Describe Responses.
(@jainruchir, #1635)
* KIP-516: Partial support of topic identifiers. Topic
identifiers in metadata response are available through the
new describe_topics function (#1645).
* KIP-396: completed the implementation with the addition of
`list_offsets` (#1576).
* Add `Rack` to the `Node` type, so AdminAPI calls can expose
racks for brokers
* Fix the Describe User Scram Credentials for Describe all
users or empty users list.
* confluent-kafka-python is based on librdkafka v2.3.0, see the
librdkafka release notes for a complete list of changes,
enhancements, fixes and upgrade considerations.
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=15
* KIP-339
* IncrementalAlterConfigs API (#1517).
* KIP-554:
* User SASL/SCRAM credentials alteration and description
(#1575).
* Added documentation with an example of FIPS compliant
communication with Kafka cluster.
* Fixed wrong error code parameter name in KafkaError.
default (which uses len) will not be used.
in a future version and the setting will then default to `False` (new format).
upgrade considerations.
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=13
- update to 2.1.1:
* Added a new ConsumerGroupState UNKNOWN. The typo state UNKOWN
is deprecated and will be removed in the next major version.
* Fix some Admin API documentation stating -1 for infinite
timeout incorrectly.
* Request timeout can't be infinite.
* Added `set_sasl_credentials`. This new method (on the
Producer, Consumer, and AdminClient) allows modifying the
stored SASL PLAIN/SCRAM credentials that will be used for
subsequent (new) connections to a broker
* Added support for Default num_partitions in CreateTopics
Admin API.
* Added support for password protected private key in
CachedSchemaRegistryClient.
* Add reference support in Schema Registry client.
* Added support for schema references.
* KIP-320: add offset leader epoch methods to the
TopicPartition and Message classes
* KIP-222 Add Consumer Group operations to Admin API.
* KIP-518 Allow listing consumer groups per state.
* KIP-396 Partially implemented: support for
AlterConsumerGroupOffsets.
* Added metadata to `TopicPartition` type and `commit()`
* Added `consumer.memberid()` for getting member id assigned to
* the consumer in a consumer group
* 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
* Deprecated `AvroProducer` and `AvroConsumer`. Use
OBS-URL: https://build.opensuse.org/request/show/1085344
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-confluent-kafka?expand=0&rev=6
* Added a new ConsumerGroupState UNKNOWN. The typo state UNKOWN
is deprecated and will be removed in the next major version.
* Fix some Admin API documentation stating -1 for infinite
timeout incorrectly.
* Request timeout can't be infinite.
* Added `set_sasl_credentials`. This new method (on the
Producer, Consumer, and AdminClient) allows modifying the
stored SASL PLAIN/SCRAM credentials that will be used for
subsequent (new) connections to a broker
* Added support for Default num_partitions in CreateTopics
Admin API.
* Added support for password protected private key in
CachedSchemaRegistryClient.
* Add reference support in Schema Registry client.
* Added support for schema references.
* KIP-320: add offset leader epoch methods to the
TopicPartition and Message classes
* KIP-222 Add Consumer Group operations to Admin API.
* KIP-518 Allow listing consumer groups per state.
* KIP-396 Partially implemented: support for
AlterConsumerGroupOffsets.
* Added metadata to `TopicPartition` type and `commit()`
* Added `consumer.memberid()` for getting member id assigned to
* the consumer in a consumer group
* 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
* Deprecated `AvroProducer` and `AvroConsumer`. Use
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=11
- Update to Version 1.9.2:
v1.9.2 is a maintenance release with the following fixes and enhancements:
- Support for setting principal and SASL extensions in oauth_cb
and handle failures (@Manicben, #1402)
- Wheel for macOS M1/arm64
- KIP-140 Admin API ACL fix:
When requesting multiple create_acls or delete_acls operations,
if the provided ACL bindings or ACL binding filters are not
unique, an exception will be thrown immediately rather than later
when the responses are read. (#1370).
- KIP-140 Admin API ACL fix:
Better documentation of the describe and delete ACLs behavior
when using the MATCH resource patter type in a filter. (#1373).
- Avro serialization examples:
added a parameter for using a generic or specific Avro schema. (#1381).
confluent-kafka-python is based on librdkafka v1.9.2, see the
[librdkafka release notes](https://github.com/edenhill/librdkafka/releases/tag/v1.9.2)
for a complete list of changes, enhancements, fixes and upgrade considerations.
- Update to Version v1.9.1:
There was no 1.9.1 release of the Python Client.
- Update to Versino 1.9.0:
This is a feature release:
- OAUTHBEARER OIDC support
- KIP-140 Admin API ACL support
### Fixes
- The warnings for `use.deprecated.format` (introduced in v1.8.2)
had its logic reversed, which result in warning logs to be emitted when
the property was correctly configured, and the log message itself also
contained text that had it backwards.
The warning is now only emitted when `use.deprecated.format` is set
OBS-URL: https://build.opensuse.org/request/show/1006270
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=9
- update to 1.7.0:
* Add error_cb to confluent_cloud.py example
* Clarify that doc output varies based on method
* Docs say Schema when they mean SchemaReference
* Add documentation for NewTopic and NewPartitions
- update to 1.6.1:
* KIP-429 - Incremental consumer rebalancing support.
* OAUTHBEARER support.
* Add return_record_name=True to AvroDeserializer
* Fix deprecated schema.Parse call
* Make reader schema optional in AvroDeserializer
* Add **kwargs to legacy AvroProducer and AvroConsumer constructors to
* support all Consumer and Producer base class constructor arguments, such
* as logger
* Add bool for permanent schema delete
* The avro package is no longer required for Schema-Registry support
* Only write to schema cache once, improving performance
* Improve Schema-Registry error reporting
* producer.flush() could return a non-zero value without hitting the specified timeout.
* Bundles librdkafka v1.6.0 which adds support for Incremental rebalancing,
* Sticky producer partitioning, Transactional producer scalabilty improvements,
* and much much more. See link to release notes below.
* Rename asyncio.py example to avoid circular import
* The Linux wheels are now built with manylinux2010 (rather than manylinux1)
* since OpenSSL v1.1.1 no longer builds on CentOS 5. Older Linux distros may
* thus no longer be supported, such as CentOS 5.
* The in-wheel OpenSSL version has been updated to 1.1.1i.
* Added Message.latency() to retrieve the per-message produce latency.
* Added trove classifiers.
OBS-URL: https://build.opensuse.org/request/show/928314
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-confluent-kafka?expand=0&rev=4
* Add error_cb to confluent_cloud.py example
* Clarify that doc output varies based on method
* Docs say Schema when they mean SchemaReference
* Add documentation for NewTopic and NewPartitions
- update to 1.6.1:
* KIP-429 - Incremental consumer rebalancing support.
* OAUTHBEARER support.
* Add return_record_name=True to AvroDeserializer
* Fix deprecated schema.Parse call
* Make reader schema optional in AvroDeserializer
* Add **kwargs to legacy AvroProducer and AvroConsumer constructors to
* support all Consumer and Producer base class constructor arguments, such
* as logger
* Add bool for permanent schema delete
* The avro package is no longer required for Schema-Registry support
* Only write to schema cache once, improving performance
* Improve Schema-Registry error reporting
* producer.flush() could return a non-zero value without hitting the specified timeout.
* Bundles librdkafka v1.6.0 which adds support for Incremental rebalancing,
* Sticky producer partitioning, Transactional producer scalabilty improvements,
* and much much more. See link to release notes below.
* Rename asyncio.py example to avoid circular import
* The Linux wheels are now built with manylinux2010 (rather than manylinux1)
* since OpenSSL v1.1.1 no longer builds on CentOS 5. Older Linux distros may
* thus no longer be supported, such as CentOS 5.
* The in-wheel OpenSSL version has been updated to 1.1.1i.
* Added Message.latency() to retrieve the per-message produce latency.
* Added trove classifiers.
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=8
* Bundles librdkafka v1.5.0 - see release notes for all enhancements and fixes.
* Dockerfile examples
* List offsets example
* confluent-kafka-python is based on librdkafka v1.5.0, see the librdkafka
release notes for a complete list of changes, enhancements, fixes and
upgrade considerations.
- no-license-as-datafile.patch (obsolete, replaced by rm in %install)
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=6
- update to 1.1.0:
* confluent-kafka-python is based on librdkafka v1.1.0, see the librdkafka v1.1.0 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
* ssl.endpoint.identification.algorithm=https (off by default) to validate the broker hostname matches the certificate. Requires OpenSSL >= 1.0.2(included with Wheel installations))
* Improved GSSAPI/Kerberos ticket refresh
* Confluent monitoring interceptor package bumped to v0.11.1 (#634)
New configuration properties:
* ssl.key.pem - client's private key as a string in PEM format
* ssl.certificate.pem - client's public key as a string in PEM format
* enable.ssl.certificate.verification - enable(default)/disable OpenSSL's builtin broker certificate verification.
* enable.ssl.endpoint.identification.algorithm - to verify the broker's hostname with its certificate (disabled by default).
* Add new rd_kafka_conf_set_ssl_cert() to pass PKCS#12, DER or PEM certs in (binary) memory form to the configuration object.
* The private key data is now securely cleared from memory after last use.
* SASL GSSAPI/Kerberos: Don't run kinit refresh for each broker, just per client instance.
* SASL GSSAPI/Kerberos: Changed sasl.kerberos.kinit.cmd to first attempt ticket refresh, then acquire.
* SASL: Proper locking on broker name acquisition.
* Consumer: max.poll.interval.ms now correctly handles blocking poll calls, allowing a longer poll timeout than the max poll interval.
* configure: Fix libzstd static lib detection
OBS-URL: https://build.opensuse.org/request/show/745369
OBS-URL: https://build.opensuse.org/package/show/openSUSE:Factory/python-confluent-kafka?expand=0&rev=2
* confluent-kafka-python is based on librdkafka v1.1.0, see the librdkafka v1.1.0 release notes for a complete list of changes, enhancements, fixes and upgrade considerations.
* ssl.endpoint.identification.algorithm=https (off by default) to validate the broker hostname matches the certificate. Requires OpenSSL >= 1.0.2(included with Wheel installations))
* Improved GSSAPI/Kerberos ticket refresh
* Confluent monitoring interceptor package bumped to v0.11.1 (#634)
New configuration properties:
* ssl.key.pem - client's private key as a string in PEM format
* ssl.certificate.pem - client's public key as a string in PEM format
* enable.ssl.certificate.verification - enable(default)/disable OpenSSL's builtin broker certificate verification.
* enable.ssl.endpoint.identification.algorithm - to verify the broker's hostname with its certificate (disabled by default).
* Add new rd_kafka_conf_set_ssl_cert() to pass PKCS#12, DER or PEM certs in (binary) memory form to the configuration object.
* The private key data is now securely cleared from memory after last use.
* SASL GSSAPI/Kerberos: Don't run kinit refresh for each broker, just per client instance.
* SASL GSSAPI/Kerberos: Changed sasl.kerberos.kinit.cmd to first attempt ticket refresh, then acquire.
* SASL: Proper locking on broker name acquisition.
* Consumer: max.poll.interval.ms now correctly handles blocking poll calls, allowing a longer poll timeout than the max poll interval.
* configure: Fix libzstd static lib detection
OBS-URL: https://build.opensuse.org/package/show/devel:languages:python/python-confluent-kafka?expand=0&rev=4
