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

* Updated BrokerMetadata#nodeId type from int to (int | str). * FIXME. * Unused import. * Include issue link in FIXME. * Fix linter errors --------- Co-authored-by: Denis Otkidach <[email protected]>
aio-libs · Nov 16, 2024 · 49a5573 · 49a5573
1 parent 23efe72
commit 49a5573
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/aiokafka/structs.py b/aiokafka/structs.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 from collections.abc import Sequence
 from dataclasses import dataclass
 from typing import Generic, NamedTuple, Optional, TypeVar
@@ -27,7 +29,8 @@ class TopicPartition(NamedTuple):
 class BrokerMetadata(NamedTuple):
     """A Kafka broker metadata used by admin tools"""
 
-    nodeId: int
+    # FIXME: consider updating implementation (https://github.com/aio-libs/aiokafka/issues/1050)
+    nodeId: int | str
     "The Kafka broker id"
 
     host: str