From c60cd0b7fc83e20506ba3afa32c59082592bb66e Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Mon, 23 Jun 2025 15:11:32 -0700 Subject: [PATCH] Drop unused imports --- kafka/consumer/group.py | 2 +- kafka/protocol/parser.py | 2 +- test/integration/test_admin_integration.py | 2 +- test/test_assignors.py | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/kafka/consumer/group.py b/kafka/consumer/group.py index 4eb9e2ab4..5ac14ebfc 100644 --- a/kafka/consumer/group.py +++ b/kafka/consumer/group.py @@ -5,7 +5,7 @@ import socket import time -from kafka.errors import KafkaConfigurationError, KafkaTimeoutError, UnsupportedVersionError +from kafka.errors import KafkaConfigurationError, UnsupportedVersionError from kafka.vendor import six diff --git a/kafka/protocol/parser.py b/kafka/protocol/parser.py index 4bc427330..8683a952a 100644 --- a/kafka/protocol/parser.py +++ b/kafka/protocol/parser.py @@ -6,7 +6,7 @@ import kafka.errors as Errors from kafka.protocol.find_coordinator import FindCoordinatorResponse from kafka.protocol.frame import KafkaBytes -from kafka.protocol.types import Int32, TaggedFields +from kafka.protocol.types import Int32 from kafka.version import __version__ log = logging.getLogger(__name__) diff --git a/test/integration/test_admin_integration.py b/test/integration/test_admin_integration.py index 1c38400e7..5292080bb 100644 --- a/test/integration/test_admin_integration.py +++ b/test/integration/test_admin_integration.py @@ -9,7 +9,7 @@ from kafka.admin import ( ACLFilter, ACLOperation, ACLPermissionType, ResourcePattern, ResourceType, ACL, ConfigResource, ConfigResourceType) from kafka.errors import ( - BrokerResponseError, KafkaError, NoError, CoordinatorNotAvailableError, NonEmptyGroupError, + BrokerResponseError, NoError, CoordinatorNotAvailableError, NonEmptyGroupError, GroupIdNotFoundError, OffsetOutOfRangeError, UnknownTopicOrPartitionError) diff --git a/test/test_assignors.py b/test/test_assignors.py index 858ef426d..91d7157d6 100644 --- a/test/test_assignors.py +++ b/test/test_assignors.py @@ -9,8 +9,8 @@ from kafka.structs import TopicPartition from kafka.coordinator.assignors.range import RangePartitionAssignor from kafka.coordinator.assignors.roundrobin import RoundRobinPartitionAssignor -from kafka.coordinator.assignors.sticky.sticky_assignor import StickyPartitionAssignor, StickyAssignorUserDataV1 -from kafka.coordinator.protocol import ConsumerProtocolMemberAssignment, ConsumerProtocolMemberMetadata +from kafka.coordinator.assignors.sticky.sticky_assignor import StickyPartitionAssignor +from kafka.coordinator.protocol import ConsumerProtocolMemberAssignment from kafka.vendor import six