1ac9af6aba
- update to 2.8.0: * 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
Dirk Mueller2025-07-18 20:21:48 +00:00
de6c13525f
Accepting request 1279521 from devel:languages:python
Ana Guerrero2025-05-26 16:33:58 +00:00
98528bb9b0
- 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.
Dirk Mueller2023-12-02 19:26:48 +00:00
f9e1159e3e
- update to 2.2.0: * 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.
Dirk Mueller2023-12-01 16:57:09 +00:00
aad33c8cab
- 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
Dirk Mueller2023-05-07 19:03:40 +00:00
54f0c7b796
Accepting request 1007771 from devel:languages:python
Richard Brown2022-10-04 18:37:44 +00:00
770ae1818f
Accepting request 1006270 from home:yarunachalam:branches:devel:languages:python
Daniel Garcia2022-09-27 07:51:04 +00:00
e8ba64b06b
- 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
Dirk Mueller2021-10-30 20:34:47 +00:00
b957bea852
- update to 1.5.0: * 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)
Dirk Mueller2020-10-13 07:20:44 +00:00
7185808c82
- 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
Dirk Mueller2019-10-31 09:18:24 +00:00
Dominique Leuenberger
Dirk Mueller
Ana Guerrero
Markéta Machová
Richard Brown
Daniel Garcia
Thomas Bechtold