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