diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2019-05-22 21:56:25 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-05-22 21:56:25 -0700 |
| commit | edfafc036f0d9a3b1e5c73f9642ef71c297c1b64 (patch) | |
| tree | cb7b43fb52deded4f2640402e45f331b26e39250 /test | |
| parent | f145e37c1992da71d5c65c0d86ae971cda62e058 (diff) | |
| download | kafka-python-edfafc036f0d9a3b1e5c73f9642ef71c297c1b64.tar.gz | |
Remove unused imports (#1808)
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_client_async.py | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/test/test_client_async.py b/test/test_client_async.py index 2132c8e..77f6b6b 100644 --- a/test/test_client_async.py +++ b/test/test_client_async.py @@ -17,15 +17,13 @@ from kafka.cluster import ClusterMetadata from kafka.conn import ConnectionStates import kafka.errors as Errors from kafka.future import Future -from kafka.protocol.metadata import MetadataResponse, MetadataRequest +from kafka.protocol.metadata import MetadataRequest from kafka.protocol.produce import ProduceRequest from kafka.structs import BrokerMetadata @pytest.fixture def cli(mocker, conn): - mocker.patch('kafka.cluster.dns_lookup', - return_value=[(socket.AF_INET, None, None, None, ('localhost', 9092))]) client = KafkaClient(api_version=(0, 9)) client.poll(future=client.cluster.request_update()) return client @@ -33,8 +31,6 @@ def cli(mocker, conn): def test_bootstrap(mocker, conn): conn.state = ConnectionStates.CONNECTED - mocker.patch('kafka.cluster.dns_lookup', - return_value=[(socket.AF_INET, None, None, None, ('localhost', 9092))]) cli = KafkaClient(api_version=(0, 9)) future = cli.cluster.request_update() cli.poll(future=future) |
