Remove experimental module designation for Async classes (#2143)

* Updated changelog for beta release and backfilled last hotfix

* Moved experimental module up a level

* Added aio files back

* Version v2.13.0b1

* Fixing sleep for Windows

* black and isort

* Disabled style check for clang-format

* Moved version info back to original version for master merge

Author: MSeal

CHANGELOG.md

@@ -1,5 +1,32 @@
 # Confluent Python Client for Apache Kafka - CHANGELOG
 
+## 2.13.0b1 - (beta) 2025-11-24
+
+This is a beta release, notes to change to full release later on in changelog. Changes included are:
+
+- Enforced type hinting for all interaces
+- Handle OAuth Token Refreshes
+- Added black and isort linting rules and enforcement to codebase
+- Fix support for wrapped Avro unions 
+- Enabled direct creation of Message objects
+- Added `close()` method to producer
+- Added context manager for librdkafka classes to enable easy scope cleanup
+- Fixed segfault exceptions on calls against objects that had closed internal objects
+- Handle evolution during field transformation of schemas
+- Expose deterministic partitioner functions
+- Handle null group name to prevent segfault in Admin `list_consumer_group_offsets()`
+- Add Accept-Version header for schemas
+- Ensure schemaId initialization is thread-safe
+- Fix error propagation rule for Python's C API
+- Fix SR delete behavior with client-side caching
+- Enhanced the BufferTimeoutManager to flush the librdkafka queue
+
+## 2.12.2 - 2025-11-06
+
+v2.12.2 is a hotfix for a critical problem found with Schema Registry clients in the 2.12.1 release:
+
+- Fix IndexOutOfBoundsException when evolving Avro schema that uses rules
+
 ## v2.12.1 - 2025-10-21
 
 v2.12.1 is a maintenance release with the following fixes:

examples/asyncio_avro_producer.py

@@ -20,7 +20,7 @@
 import argparse
 import asyncio
 
-from confluent_kafka.experimental.aio import AIOProducer
+from confluent_kafka.aio import AIOProducer
 from confluent_kafka.schema_registry import AsyncSchemaRegistryClient
 from confluent_kafka.schema_registry._async.avro import AsyncAvroSerializer
 from confluent_kafka.serialization import MessageField, SerializationContext

examples/asyncio_example.py

@@ -20,7 +20,7 @@
 import signal
 import sys
 
-from confluent_kafka.experimental.aio import AIOConsumer, AIOProducer
+from confluent_kafka.aio import AIOConsumer, AIOProducer
 
 # This example demonstrates comprehensive AsyncIO usage patterns with Kafka:
 # - Event loop safe callbacks that don't block the loop

src/confluent_kafka/__init__.py

@@ -54,7 +54,7 @@
 __all__ = [
     "admin",
     "Consumer",
-    "experimental",
+    "aio",
     "KafkaError",
     "KafkaException",
     "kafkatest",

…t_kafka/experimental/aio/_AIOConsumer.py src/confluent_kafka/aio/_AIOConsumer.pysrc/confluent_kafka/experimental/aio/_AIOConsumer.py renamed to src/confluent_kafka/aio/_AIOConsumer.py src/confluent_kafka/experimental/aio/_AIOConsumer.py renamed to src/confluent_kafka/aio/_AIOConsumer.py

@@ -13,7 +13,7 @@
 # limitations under the License.
 
 """
-Confluent Kafka Experimental AIOProducer Module
+Confluent Kafka AIOProducer Module
 
 This module contains all the components for the async Kafka producer.
 """