Updated BrokerMetadata#nodeId type from int to (int | str).

jackgene · Nov 3, 2024 · e9697cc · e9697cc
1 parent 23efe72
commit e9697cc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/aiokafka/structs.py b/aiokafka/structs.py
@@ -1,6 +1,6 @@
 from collections.abc import Sequence
 from dataclasses import dataclass
-from typing import Generic, NamedTuple, Optional, TypeVar
+from typing import Generic, List, NamedTuple, Optional, Sequence, Tuple, TypeVar, Union
 
 from aiokafka.errors import KafkaError
 
@@ -27,7 +27,7 @@ class TopicPartition(NamedTuple):
 class BrokerMetadata(NamedTuple):
     """A Kafka broker metadata used by admin tools"""
 
-    nodeId: int
+    nodeId: Union[int, str]
     "The Kafka broker id"
 
     host: str