From e9697cc888bb3bf922c685406abbe681bd3c7edb Mon Sep 17 00:00:00 2001 From: Jack Leow Date: Mon, 7 Oct 2024 09:51:11 -0700 Subject: [PATCH] Updated BrokerMetadata#nodeId type from int to (int | str). --- aiokafka/structs.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/aiokafka/structs.py b/aiokafka/structs.py index 3db1d20a..748243cc 100644 --- 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