diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2018-05-28 15:58:26 -0700 |
---|---|---|
committer | Jeff Widman <jeff@jeffwidman.com> | 2018-06-05 14:32:01 -0700 |
commit | bc4cc434cddf403a35d0393d68ecfdbfad17c8e5 (patch) | |
tree | b74c5190a0fd74afffb5318d4bd34b59ae33e25c /test/test_fetcher.py | |
parent | 81cda595b3ecf17737b4e4d86efa230db2e9bd31 (diff) | |
download | kafka-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.py | 4 |
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 |