Remove a few unused imports

kafka/client_async.py

@@ -28,7 +28,8 @@
 from .metrics.stats import Avg, Count, Rate
 from .metrics.stats.rate import TimeUnit
 from .protocol.metadata import MetadataRequest
-from .protocol.produce import ProduceRequest
+# Although this looks unused, it actually monkey-patches socket.socketpair()
+# and should be left in as long as we're using socket.socketpair() in this file
 from .vendor import socketpair
 from .version import __version__
 

kafka/conn.py

@@ -19,7 +19,6 @@
 from kafka.protocol.commit import GroupCoordinatorResponse, OffsetFetchRequest
 from kafka.protocol.frame import KafkaBytes
 from kafka.protocol.metadata import MetadataRequest
-from kafka.protocol.fetch import FetchRequest
 from kafka.protocol.types import Int32
 from kafka.version import __version__
 

kafka/consumer/group.py

@@ -3,7 +3,6 @@
 import copy
 import logging
 import socket
-import sys
 import time
 
 from kafka.errors import KafkaConfigurationError, UnsupportedVersionError

kafka/producer/sender.py

@@ -10,7 +10,7 @@
 
 from .. import errors as Errors
 from ..metrics.measurable import AnonMeasurable
-from ..metrics.stats import Avg, Count, Max, Rate
+from ..metrics.stats import Avg, Max, Rate
 from ..protocol.produce import ProduceRequest
 from ..structs import TopicPartition
 from ..version import __version__