From a27d11356caf8d2cac399a0a031259361fcca43d Mon Sep 17 00:00:00 2001 From: Pranav Rathi <4427674+pranavrth@users.noreply.github.com> Date: Wed, 25 Oct 2023 23:09:04 +0530 Subject: [PATCH] Few Changelog and doc changes. Final release version. (#1666) --- CHANGELOG.md | 4 +++- docs/conf.py | 2 +- setup.py | 2 +- src/confluent_kafka/deserializing_consumer.py | 4 ++-- src/confluent_kafka/src/confluent_kafka.h | 2 +- 5 files changed, 8 insertions(+), 6 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 0ee4040f3..85f5ee106 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,9 +5,11 @@ v2.3.0 is a feature release with the following features, fixes and enhancements: - Add Python 3.12 wheels - - Add support for AdminAPI `DescribeCluster()` and `DescribeTopics()`. (@jainruchir, #1635) + - [KIP-117](https://cwiki.apache.org/confluence/display/KAFKA/KIP-117%3A+Add+a+public+AdminClient+API+for+Kafka+admin+operations): Add support for AdminAPI `describe_cluster()` and `describe_topics()`. (@jainruchir, #1635) - [KIP-430](https://cwiki.apache.org/confluence/display/KAFKA/KIP-430+-+Return+Authorized+Operations+in+Describe+Responses): Return authorized operations in Describe Responses. (@jainruchir, #1635) + - [KIP-516](https://cwiki.apache.org/confluence/display/KAFKA/KIP-516%3A+Topic+Identifiers): Partial support of topic identifiers. Topic identifiers in metadata response are available through the new describe_topics function (#1645). + - [KIP-396](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=97551484): completed the implementation with the addition of `list_offsets` (#1576). - Add `Rack` to the `Node` type, so AdminAPI calls can expose racks for brokers (currently, all Describe Responses) (#1635, @jainruchir). - Fix the Describe User Scram Credentials for Describe all users or empty users list. Please refer to diff --git a/docs/conf.py b/docs/conf.py index b0c62c7e1..83e978957 100644 --- a/docs/conf.py +++ b/docs/conf.py @@ -35,7 +35,7 @@ # built documents. # # The short X.Y version. -version = '2.3.0rc4' +version = '2.3.0' # The full version, including alpha/beta/rc tags. release = version ###################################################################### diff --git a/setup.py b/setup.py index e17e712ce..819324850 100755 --- a/setup.py +++ b/setup.py @@ -75,7 +75,7 @@ def get_install_requirements(path): setup(name='confluent-kafka', # Make sure to bump CFL_VERSION* in confluent_kafka/src/confluent_kafka.h # and version in docs/conf.py. - version='2.3.0rc4', + version='2.3.0', description='Confluent\'s Python client for Apache Kafka', author='Confluent Inc', author_email='support@confluent.io', diff --git a/src/confluent_kafka/deserializing_consumer.py b/src/confluent_kafka/deserializing_consumer.py index 39f80943d..294dae99d 100644 --- a/src/confluent_kafka/deserializing_consumer.py +++ b/src/confluent_kafka/deserializing_consumer.py @@ -40,11 +40,11 @@ class DeserializingConsumer(_ConsumerImpl): +-------------------------+---------------------+-----------------------------------------------------+ | Property Name | Type | Description | +=========================+=====================+=====================================================+ - | | | Callable(SerializationContext, bytes) -> obj | + | | | Callable(bytes, SerializationContext) -> obj | | ``key.deserializer`` | callable | | | | | Deserializer used for message keys. | +-------------------------+---------------------+-----------------------------------------------------+ - | | | Callable(SerializationContext, bytes) -> obj | + | | | Callable(bytes, SerializationContext) -> obj | | ``value.deserializer`` | callable | | | | | Deserializer used for message values. | +-------------------------+---------------------+-----------------------------------------------------+ diff --git a/src/confluent_kafka/src/confluent_kafka.h b/src/confluent_kafka/src/confluent_kafka.h index 98942db52..16cdf3d65 100644 --- a/src/confluent_kafka/src/confluent_kafka.h +++ b/src/confluent_kafka/src/confluent_kafka.h @@ -43,7 +43,7 @@ * MM=major, mm=minor, RR=revision, PP=patchlevel (not used) */ #define CFL_VERSION 0x02030000 -#define CFL_VERSION_STR "2.3.0rc4" +#define CFL_VERSION_STR "2.3.0" /** * Minimum required librdkafka version. This is checked both during