diff options
| author | Dana Powers <dana.powers@rd.io> | 2014-08-31 10:48:19 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2014-09-04 18:05:05 -0700 |
| commit | 8d85ed11248c23d8a8983664556784d08e64910f (patch) | |
| tree | 2ba5a426d1bf7588a933731f14aa63fe5853f597 | |
| parent | 3ec3989ca1ef14cf0b84ecf4e5e5f9c5e0eb00aa (diff) | |
| download | kafka-python-8d85ed11248c23d8a8983664556784d08e64910f.tar.gz | |
Minor import cleanups
| -rw-r--r-- | kafka/conn.py | 2 | ||||
| -rw-r--r-- | kafka/consumer.py | 12 |
2 files changed, 7 insertions, 7 deletions
diff --git a/kafka/conn.py b/kafka/conn.py index a1b0a80..a577eba 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -1,8 +1,8 @@ import copy import logging +from random import shuffle import socket import struct -from random import shuffle from threading import local from kafka.common import ConnectionError diff --git a/kafka/consumer.py b/kafka/consumer.py index 0935dd2..928bbac 100644 --- a/kafka/consumer.py +++ b/kafka/consumer.py @@ -8,12 +8,12 @@ from threading import Lock from multiprocessing import Process, Queue as MPQueue, Event, Value from Queue import Empty, Queue -import kafka +import kafka.common from kafka.common import ( - FetchRequest, - OffsetRequest, OffsetCommitRequest, - OffsetFetchRequest, - ConsumerFetchSizeTooSmall, ConsumerNoMoreData + FetchRequest, OffsetRequest, + OffsetCommitRequest, OffsetFetchRequest, + ConsumerFetchSizeTooSmall, ConsumerNoMoreData, + UnknownTopicOrPartitionError ) from kafka.util import ReentrantTimer @@ -114,7 +114,7 @@ class Consumer(object): try: kafka.common.check_error(resp) return resp.offset - except kafka.common.UnknownTopicOrPartitionError: + except UnknownTopicOrPartitionError: return 0 for partition in partitions: |