summaryrefslogtreecommitdiff
path: root/test/test_fetcher.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2018-05-28 15:58:26 -0700
committerJeff Widman <jeff@jeffwidman.com>2018-06-05 14:32:01 -0700
commitbc4cc434cddf403a35d0393d68ecfdbfad17c8e5 (patch)
treeb74c5190a0fd74afffb5318d4bd34b59ae33e25c /test/test_fetcher.py
parent81cda595b3ecf17737b4e4d86efa230db2e9bd31 (diff)
downloadkafka-python-bc4cc434cddf403a35d0393d68ecfdbfad17c8e5.tar.gz
Don't use `kafka.common` internally1.3.5
This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
Diffstat (limited to 'test/test_fetcher.py')
-rw-r--r--test/test_fetcher.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/test/test_fetcher.py b/test/test_fetcher.py
index fc031f7..c821018 100644
--- a/test/test_fetcher.py
+++ b/test/test_fetcher.py
@@ -12,16 +12,16 @@ from kafka.consumer.fetcher import (
CompletedFetch, ConsumerRecord, Fetcher, NoOffsetForPartitionError
)
from kafka.consumer.subscription_state import SubscriptionState
+from kafka.future import Future
from kafka.metrics import Metrics
from kafka.protocol.fetch import FetchRequest, FetchResponse
from kafka.protocol.offset import OffsetResponse
-from kafka.structs import TopicPartition
-from kafka.future import Future
from kafka.errors import (
StaleMetadata, LeaderNotAvailableError, NotLeaderForPartitionError,
UnknownTopicOrPartitionError, OffsetOutOfRangeError
)
from kafka.record.memory_records import MemoryRecordsBuilder, MemoryRecords
+from kafka.structs import TopicPartition
@pytest.fixture