diff options
author | Jeff Widman <jeff@jeffwidman.com> | 2018-05-28 15:58:26 -0700 |
---|---|---|
committer | Jeff Widman <jeff@jeffwidman.com> | 2018-05-28 16:30:07 -0700 |
commit | c666b4e251757b827d52d62f9d4a18ab5e728897 (patch) | |
tree | b74c5190a0fd74afffb5318d4bd34b59ae33e25c /test/test_fetcher.py | |
parent | 81cda595b3ecf17737b4e4d86efa230db2e9bd31 (diff) | |
download | kafka-python-dont-use-kafka.common-internally.tar.gz |
Don't use `kafka.common` internallydont-use-kafka.common-internally
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 |