further edits

Author: dpkp

CHANGES.md

@@ -44,21 +44,18 @@ Complete refactor of the networking layer using a bespoke event-loop supporting
 * connection: short-circuit send/recv when closed (#2967)
 
 ### Transports and Proxies
-Built-in support for SSL, SOCKS5, and HTTP CONNECT proxy connections, plus sensible defaults for modern TLS.
 * Default SSLContext -> PROTOCOL_TLS_CLIENT; minimum version TLS 1.2 (#2807)
 * Enable TCP KeepAlive as default socket option (#2904)
 * kafka.net: HTTP CONNECT proxy support (RFC 7231 s4.3.6) (#2990)
 
 ### SASL Authentication
-* kafka.net: SASL authentication support (#2814, #2886, #2994, #3026)
 * kafka.net: Validate SASL/SCRAM iterations (#3026)
 * SASL: Prefer node hostname to IP address when building mechanisms (#3003)
 
 ### Timeouts and Connection Management
 Per-request and per-stage timeouts replace the old single client-wide timeout.
 * KIP-601: support socket_connection_setup_timeout_ms w/ exponential backoff (#3027)
 * kafka.net: Bootstrap if needed for metadata refresh (#2825)
-* kafka.net.manager: Close before stopping IO thread; fail pending bootstrap (#2934)
 * kafka.net: Raise UnknownBrokerIdError when connection fails because node_id is not in metadata (#2876)
 
 ### Futures and Wakeups
@@ -69,7 +66,7 @@ The `Future` primitive gains `__await__` and a faster slotted implementation; cr
 * WakeupNotifier primitive for cross-thread/task wakeups (#2925, #2933)
 
 ### Concurrency and Error Handling
-Defensive checks throughout the event loop and transport stack: improved socket I/O error handling, RuntimeErrors on misuse of the IO thread, and lock-based detection of concurrent access.
+Defensive checks throughout the kafka.net event loop and transport stack: improved socket I/O error handling, RuntimeErrors on misuse of the IO thread, and lock-based detection of concurrent access.
 * kafka.net.selector: Break scheduled heapq ties when tasks share scheduled_at (#3007)
 * kafka.net.selector: Monitor slow tasks with slow_task_threshold_secs (#2946)
 * kafka.net.selector: Use threading.Lock() to detect concurrent access to poll() (#2945)
@@ -80,31 +77,25 @@ Defensive checks throughout the event loop and transport stack: improved socket
 * kafka.net: Catch unhandled exceptions in IO thread (#2970)
 * kafka.net: Improve error handling on sock read/write (#2995)
 * kafka.net.transport: Close connection on socket write error (#2973)
-* kafka.net.transport: Fix double EVENT_WRITE register on socket (#2972)
-* kafka.net.transport: Handle OSError on sock when constructing __str__ (#2926)
-* kafka.net: Fix notify/wakeup race w/ pending flag (#2979)
-* kafka.net: Drop manager.poll(); call net.poll directly (#2948)
 * kafka.net: Check locks in _poll_once; add net.drain() (#2949)
 
 ## Protocol
 
-The a new JSON-schema-based dynamic protocol generator now replaces the legacy hand-written protocol classes (moved to `kafka.protocol.old`).
+A new JSON-schema-based dynamic protocol generator now replaces the legacy hand-written protocol classes (moved to `kafka.protocol.old`).
 
 ### Dynamic Protocol Classes
-Protocol classes are now generated from the upstream Apache Kafka JSON schemas, with type stubs for IDE support and a registry-based lookup for headers and responses.
+Protocol classes are now generated from the upstream Apache Kafka JSON schemas.
 * Dynamic protocol classes using upstream json schemas (#2727, #2745, #2779, #2782, #2787, #2810)
 * Add .pyi type annotation stubs for generated protocol classes (#2784)
 * Migrate all internal usage to new protocol classes (#2764, #2765, #2766, #2767, #2768, #2772)
 * Refactor treatment of versioned ApiMessage classes (#2739)
 * Lookup request header -> response class via ResponseClassRegistry (#2730)
-* Combine broker_version/api_versions -> versions.py (#2913)
 * Manual json schema edits to restore fields dropped in Apache 4.0 (#2738)
 
 ### New Types and Messages
 * Add UUID protocol type (#2703)
 * Add UnsignedInt16 type
-* KIP-893: support nullable structs; add DescribeTopicPartitions (#2889)
-* Add DescribeQuorum protocol message
+* KIP-893: support nullable structs (#2889)
 * Replace kafka.structs BrokerMetadata/PartitionMetadata with MetadataResponse structs (#2794)
 * Add ConsumerProtocol data schemas (#2754)
 * Add StickyAssignorUserData json schema (#2755)
@@ -133,7 +124,7 @@ Broker version inference is consolidated into a single `BrokerVersionData` helpe
 
 ### BrokerVersionData
 * BrokerVersionData: consolidated version checks (#2795)
-* BrokerVersionData: infer up to 4.2 (#2835, #2836)
+* BrokerVersionData: infer up to 4.3 (#2835, #2836, #3032)
 * BrokerVersionData: support request min/max version (#2868)
 * BrokerVersionData: Fix IncompatibleBrokerVersion errors; add __str__ (#2804)
 
@@ -163,7 +154,7 @@ All consumer network I/O now flows through the shared kafka.net IO thread; `cons
 * Consumer: send all requests from net io thread (#2980)
 * Consumer: simplify poll() with fetcher.fetch_records (#2960)
 * Consumer: drop poll loop optimizations for pending offset resets and rejoins (#2959)
-* Consumer: _update_fetch_positions -> _refresh_committed_offsets; dont poll in position() (#2958)
+* Consumer: `_update_fetch_positions` -> `_refresh_committed_offsets`; dont poll in position() (#2958)
 * Consumer: convert fetcher reset_offsets/send_list_offsets_requests to async def
 * Consumer: use new proto attrs in Fetcher (ListOffsets/Fetch) (#2923)
 
@@ -203,26 +194,22 @@ All consumer network I/O now flows through the shared kafka.net IO thread; `cons
 KafkaProducer gains a sticky partitioner (KIP-480), enabled-by-default idempotence (KIP-679), tightened transaction handling, and a faster send/encode path.
 
 ### Transactions and Idempotence
-Producer epoch bumping, transaction-group metadata, and stricter ordering/error semantics bring the transactional producer in line with the Java client.
 * KIP-360 (pt1): Add transaction manager state and helper methods (#2852)
 * KIP-360 (pt2): Bump producer epoch with InitProducerIdRequest v3 on 2.5+ brokers (#2853)
-* KIP-447: Include group metadata in TxnOffsetCommitRequest (#2984)
-* KIP-447: Fixups to align with java client (#2988)
+* KIP-447: Include group metadata in TxnOffsetCommitRequest (#2984, #2988)
 * KIP-654: Txn Producer aborts with non-fatal TransactionAbortedError (#3010)
 * KAFKA-5793: Tighten up semantics of OutOfOrderSequenceNumber (pt1) (#2843)
 * Enable producer idempotence with max_in_flight_requests_per_connection > 1 (#2841)
 * Producer: Enforce guaranteed message order when idempotence_enabled (#2937)
 * Producer: treat InvalidProducerEpochError as ProducerFencedError (#2885)
 * Producer: Improve transaction manager retriable error handling (#2884)
 * Producer: Use new-style request construction in Txn Manager (#2983)
-* Reuse InitProducerIdHandler for idempotent producer
 
 ### Partitioning
-* KIP-480: StickyPartitioner for KafkaProducer (#2982)
-* KIP-480: Fixup StickyPartitioner edge-cases (#2989)
+* KIP-480: StickyPartitioner for KafkaProducer (#2982, #2989)
 
 ### Batching and Send Path
-Oversized batches now split-and-resend instead of failing, and the hot send path avoids redundant validation and buffer copies.
+Split-and-resend oversized batches instead of failing; avoid redundant validation and buffer copies on hot send-path.
 * KIP-126: Allow KafkaProducer to split and resend oversized batches (#2839)
 * Refactor producer.send / _wait_on_metadata for fast path (#2850)
 * Only ensure_valid_topic_name new topics on send (#2849)
@@ -235,18 +222,15 @@ Oversized batches now split-and-resend instead of failing, and the hot send path
 
 ## Admin Client
 
-KafkaAdminClient has been split into focused mixin classes (cluster, topics, configs, groups, ACLs, log dirs, …) and its request-sending path has been converted to async coroutines running on the shared IO thread. Adds first-class support for several KIPs along with a number of new APIs.
+Split KafkaAdminClient into focused mixin classes (cluster, topics, configs, groups, ACLs, log dirs, etc), and convert request-sending path to async def methods that run on the kafka.net IO thread. Support for new KIPs using new protocol stack.
 
 ### Refactor and Async Migration
-The admin client is now async end-to-end, with cached coordinator lookups and a mixin layout that mirrors the broker's logical resource groups.
-* Admin: split into functional mixin classes (#2873)
+The admin client interface remains sync but wraps a fully-async internal api (does not support asyncio yet). Adds cached coordinator lookups and a mixin structure to separate logical resource groups.
+* Admin: split into functional mixin classes (#2873, #2877, #2882)
 * Admin: convert request paths to async; cache coordinator_ids (#2851, #2862, #2863, #2866, #2867, #2870, #2871)
-* Admin: refactor _send_request_to_controller error handling (#2751)
-* Admin mixin fixes and shuffling method ownership (#2877)
-* Admin: rename MetadataAdminMixin -> ClusterAdminMixin; move log dirs under cluster (#2882)
+* Admin: refactor `_send_request_to_controller` error handling (#2751)
 
 ### KIP Support
-* KIP-516: Initial topic id (uuid) support (#3031)
 * KIP-699: FindCoordinatorRequest v4 -- multi-group support (#3025)
 * KIP-709: OffsetFetch v8 -- use batch interface when available (#3024)
 
@@ -261,7 +245,7 @@ The admin client is now async end-to-end, with cached coordinator lookups and a
 * Admin: Improve alter_configs w/ filters and missing keys (#2899)
 
 ### Topics and Partitions
-* Admin: Accept topic id (uuid) in _get_cluster_metadata and describe_topics
+* KIP-516: Support topic id (uuid) for describe topics (#3031)
 * Admin: re-use config processing for CreateTopicsResponse
 * Admin: wait_for_topics() and create_topics() wait_for_metadata option (#2856)
 * Admin: list_partition_offsets (#2894)
@@ -283,7 +267,7 @@ The admin client is now async end-to-end, with cached coordinator lookups and a
 
 ## CLI
 
-The CLI gains shared parser machinery, SASL/SSL connection support across all subcommands, and several new admin subcommands (acls, configs alter, users).
+The CLI adds shared parser config, SASL/SSL connection support across all subcommands, and several new admin subcommands (acls, configs alter, users).
 
 ### Common Infrastructure
 * kafka.cli: common parser args; support sasl/ssl connections (#2887)
@@ -305,8 +289,8 @@ The CLI gains shared parser machinery, SASL/SSL connection support across all su
 Small quality-of-life additions to the public API surface.
 
 * Support context manager interface for consumer/producer/admin (#2969)
-* Add OffsetSpec / IsolationLevel to kafka imports (#2898)
 * Make IncompatibleBrokerVersion a subclass of UnsupportedVersionError (#2924)
+* Add OffsetSpec / IsolationLevel to kafka imports (#2898)
 
 ## Fixes
 
@@ -344,11 +328,10 @@ A new in-memory `MockBroker` / `MockTransport` enables deterministic protocol-le
 
 * Enable pylint workflow; disable/fix all outstanding errors (#2701)
 * Add coverage step to CI (#2786)
-* CI test matrix updated to Kafka 4.0-4.2 (#2836)
+* CI test matrix updated to Kafka 4.0-4.3 (#2836, #3032)
 * Enable manual workflow runs for Python Package
 * Add lint-unicode make target; include in make lint test (#2993)
 * pyproject updates: no more universal wheels; tested on py3.8+
-* Bump version to 3.0.0.dev
 * Bump actions/cache from 4 to 5 (#2702)
 * Bump actions/upload-artifact from 4 to 7 (#2789)