summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2019-05-22 21:56:25 -0700
committerGitHub <noreply@github.com>2019-05-22 21:56:25 -0700
commitedfafc036f0d9a3b1e5c73f9642ef71c297c1b64 (patch)
treecb7b43fb52deded4f2640402e45f331b26e39250 /test
parentf145e37c1992da71d5c65c0d86ae971cda62e058 (diff)
downloadkafka-python-edfafc036f0d9a3b1e5c73f9642ef71c297c1b64.tar.gz
Remove unused imports (#1808)
Diffstat (limited to 'test')
-rw-r--r--test/test_client_async.py6
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)