fix review

aiokafka/protocol/fetch.py

@@ -1,3 +1,5 @@
+from typing import List, Optional, Tuple
+
 from .api import Request, Response
 from .types import Array, Bytes, Int8, Int16, Int32, Int64, Schema, String
 
@@ -23,6 +25,8 @@ class FetchResponse_v0(Response):
         )
     )
 
+    topics: Optional[List[Tuple[str, List[Tuple[int, int, int, bytes]]]]]
+
 
 class FetchResponse_v1(Response):
     API_KEY = 1
@@ -235,6 +239,8 @@ class FetchRequest_v0(Request):
         ),
     )
 
+    min_bytes: Optional[int]
+
 
 class FetchRequest_v1(Request):
     API_KEY = 1

tests/test_protocol.py

@@ -285,8 +285,9 @@ def test_decode_fetch_response_partial() -> None:
         ]
     )
     resp = FetchResponse_v0.decode(io.BytesIO(encoded))
-    assert len(resp.topics) == 1  # type: ignore[attr-defined]
-    topic, partitions = resp.topics[0]  # type: ignore[attr-defined]
+    assert resp.topics is not None
+    assert len(resp.topics) == 1
+    topic, partitions = resp.topics[0]
     assert topic == "foobar"
     assert len(partitions) == 2
 
@@ -303,7 +304,7 @@ def test_struct_unrecognized_kwargs() -> None:
 
 def test_struct_missing_kwargs() -> None:
     fr = FetchRequest_v0(max_wait_time=100)
-    assert fr.min_bytes is None  # type: ignore[attr-defined]
+    assert fr.min_bytes is None
 
 
 def test_unsigned_varint_serde() -> None: