diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java index de26f15cc..8688627e0 100644 --- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java +++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/ReadyPulsarOp.java @@ -461,7 +461,7 @@ public class ReadyPulsarOp implements OpDispenser { try { nsMsgDedup = pulsarAdmin.namespaces().getDeduplicationStatus(namespace); } - catch (PulsarAdminException pae) { + catch (Exception e) { // it is fine if we're unable to check namespace level setting; use default } @@ -471,7 +471,7 @@ public class ReadyPulsarOp implements OpDispenser { try { topicMsgDedup = pulsarAdmin.topics().getDeduplicationStatus(topic); } - catch (PulsarAdminException pae) { + catch (Exception e) { // it is fine if we're unable to check topic level setting; use default }