[kafka-python] Update to 2.3.2 (#15864)

Add a few additional annotations

Author: srittau

stubs/kafka-python/METADATA.toml

@@ -1,2 +1,2 @@
-version = "2.3.*"
+version = "2.3.2"
 upstream-repository = "https://github.com/dpkp/kafka-python"

stubs/kafka-python/kafka/errors.pyi

@@ -26,6 +26,8 @@ class KafkaProtocolError(KafkaError):
 class CorrelationIdError(KafkaProtocolError):
     retriable: bool
 
+class InvalidReceiveError(KafkaProtocolError): ...
+
 class KafkaTimeoutError(KafkaError):
     retriable: bool
 

stubs/kafka-python/kafka/protocol/parser.pyi

@@ -1,11 +1,15 @@
 from _typeshed import Incomplete
+from collections import deque
+from logging import Logger
 
-log: Incomplete
+log: Logger
 
 class KafkaProtocol:
-    in_flight_requests: Incomplete
-    bytes_to_send: Incomplete
-    def __init__(self, client_id=None, api_version=None) -> None: ...
-    def send_request(self, request, correlation_id=None): ...
-    def send_bytes(self): ...
-    def receive_bytes(self, data): ...
+    in_flight_requests: deque[tuple[int, Incomplete]]
+    bytes_to_send: list[bytes]
+    def __init__(
+        self, client_id: str | None = None, api_version: tuple[int, int, int] | None = None, max_frame_size: int = 100000000
+    ) -> None: ...
+    def send_request(self, request, correlation_id: int | None = None) -> int: ...
+    def send_bytes(self) -> bytes: ...
+    def receive_bytes(self, data: bytes) -> list[Incomplete]: ...