Remove unused imports

kafka/cluster.py

@@ -3,7 +3,6 @@ from __future__ import absolute_import
 import collections
 import copy
 import logging
-import random
 import threading
 import time
 

kafka/consumer/simple.py

@@ -26,7 +26,7 @@ from .base import (
 )
 from ..common import (
     FetchRequestPayload, KafkaError, OffsetRequestPayload,
-    ConsumerFetchSizeTooSmall, ConsumerNoMoreData,
+    ConsumerFetchSizeTooSmall,
     UnknownTopicOrPartitionError, NotLeaderForPartitionError,
     OffsetOutOfRangeError, FailedPayloadsError, check_error
 )

kafka/coordinator/heartbeat.py

@@ -1,8 +1,6 @@
 import copy
 import time
 
-import kafka.errors as Errors
-
 
 class Heartbeat(object):
     DEFAULT_CONFIG = {

kafka/future.py

@@ -1,8 +1,6 @@
 import functools
 import logging
 
-import kafka.errors as Errors
-
 log = logging.getLogger(__name__)
 
 

kafka/producer/kafka.py

@@ -3,7 +3,6 @@ from __future__ import absolute_import
 import atexit
 import copy
 import logging
-import signal
 import threading
 import time
 

kafka/producer/record_accumulator.py

@@ -6,14 +6,11 @@ import logging
 import threading
 import time
 
-import six
-
 from .. import errors as Errors
-from ..structs import TopicPartition
 from ..protocol.message import Message, MessageSet
 from .buffer import MessageSetBuffer, SimpleBufferPool
 from .future import FutureRecordMetadata, FutureProduceResult
-
+from ..structs import TopicPartition
 
 
 log = logging.getLogger(__name__)

kafka/producer/simple.py

@@ -3,7 +3,6 @@ from __future__ import absolute_import
 from itertools import cycle
 import logging
 import random
-import six
 
 from six.moves import xrange