diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManager.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManager.java index b003c656353c0..c426538aee4ed 100644 --- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManager.java +++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManager.java @@ -292,7 +292,7 @@ public void unregisterLedgerMetadataListener(long ledgerId, } } - private static final Pattern ledgerPathRegex = Pattern.compile("/L[0-9]+$"); + private static final Pattern ledgerPathRegex = Pattern.compile(".*/L[0-9]+$"); private void handleDataNotification(Notification n) { if (!n.getPath().startsWith(ledgerRootPath)