diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminCrtTopOp.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminCrtTopOp.java
index 483580ba3..5165d333d 100644
--- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminCrtTopOp.java
+++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarAdminCrtTopOp.java
@@ -7,7 +7,8 @@ import org.apache.pulsar.client.admin.PulsarAdmin;
 import org.apache.pulsar.client.admin.PulsarAdminException;
 import org.apache.pulsar.client.admin.Topics;
 
-public class PulsarAdminCrtTopOp implements PulsarOp {
+
+public class PulsarAdminCrtTopOp extends SyncPulsarOp {
 
     private final static Logger logger = LogManager.getLogger(PulsarAdminCrtTopOp.class);