Skip to content

Commit c478d0c

Browse files
committed
Remove unused imports
1 parent ee43e3a commit c478d0c

File tree

7 files changed

+2
-12
lines changed

7 files changed

+2
-12
lines changed

kafka/cluster.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
import collections
44
import copy
55
import logging
6-
import random
76
import threading
87
import time
98

kafka/consumer/simple.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
)
2727
from ..common import (
2828
FetchRequestPayload, KafkaError, OffsetRequestPayload,
29-
ConsumerFetchSizeTooSmall, ConsumerNoMoreData,
29+
ConsumerFetchSizeTooSmall,
3030
UnknownTopicOrPartitionError, NotLeaderForPartitionError,
3131
OffsetOutOfRangeError, FailedPayloadsError, check_error
3232
)

kafka/coordinator/heartbeat.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
import copy
22
import time
33

4-
import kafka.errors as Errors
5-
64

75
class Heartbeat(object):
86
DEFAULT_CONFIG = {

kafka/future.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,6 @@
11
import functools
22
import logging
33

4-
import kafka.errors as Errors
5-
64
log = logging.getLogger(__name__)
75

86

kafka/producer/kafka.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
import atexit
44
import copy
55
import logging
6-
import signal
76
import threading
87
import time
98

kafka/producer/record_accumulator.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,11 @@
66
import threading
77
import time
88

9-
import six
10-
119
from .. import errors as Errors
12-
from ..structs import TopicPartition
1310
from ..protocol.message import Message, MessageSet
1411
from .buffer import MessageSetBuffer, SimpleBufferPool
1512
from .future import FutureRecordMetadata, FutureProduceResult
16-
13+
from ..structs import TopicPartition
1714

1815

1916
log = logging.getLogger(__name__)

kafka/producer/simple.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@
33
from itertools import cycle
44
import logging
55
import random
6-
import six
76

87
from six.moves import xrange
98

0 commit comments

Comments
 (0)