[fix][test] Fix the compilation issue introduced in apache#20597

(cherry picked from commit 7b6d1c9)
datastax · Jul 17, 2023 · b8b5762 · b8b5762
1 parent 0b03570
commit b8b5762
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java b/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java
@@ -116,7 +116,7 @@ public PersistentReplicator(PersistentTopic topic, ManagedCursor cursor, String
                 replicationClient);
         this.topic = topic;
         this.cursor = cursor;
-        this.expiryMonitor = new PersistentMessageExpiryMonitor(localTopic,
+        this.expiryMonitor = new PersistentMessageExpiryMonitor((PersistentTopic) localTopic,
                 Codec.decode(cursor.getName()), cursor, null);
         HAVE_PENDING_READ_UPDATER.set(this, FALSE);
         PENDING_MESSAGES_UPDATER.set(this, 0);