diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
index 630810b43..2039e60a0 100644
--- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
+++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/PulsarActivity.java
@@ -78,6 +78,10 @@ public class PulsarActivity extends SimpleActivity implements ActivityDefObserve
     public void shutdownActivity() {
         super.shutdownActivity();
 
+        if (pulsarCache == null) {
+            return;
+        }
+
         for (PulsarSpace pulsarSpace : pulsarCache.getAssociatedPulsarSpace()) {
             pulsarSpace.shutdownPulsarSpace();
         }