diff --git a/bluesky_kafka/tests/conftest.py b/bluesky_kafka/tests/conftest.py
index a4610aa..81e4586 100644
--- a/bluesky_kafka/tests/conftest.py
+++ b/bluesky_kafka/tests/conftest.py
@@ -4,7 +4,6 @@
 
 from contextlib import contextmanager
 
-import intake
 import numpy as np
 import pytest
 import yaml
@@ -536,6 +535,8 @@ def numpy_md(request):
 
 @pytest.fixture(scope="function")
 def data_broker(request, mongo_uri):
+    intake = pytest.importorskip('intake')
+
     TMP_DIR = tempfile.mkdtemp()
     YAML_FILENAME = "intake_test_catalog.yml"