From c666b4e251757b827d52d62f9d4a18ab5e728897 Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Mon, 28 May 2018 15:58:26 -0700 Subject: Don't use `kafka.common` internally This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. --- test/test_fetcher.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'test/test_fetcher.py') 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 -- cgit v1.2.1