diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
index 7b2232f4b20ee..020b961698025 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java
@@ -778,7 +778,8 @@ private CompletableFuture<Consumer> internalSubscribe(final TransportCnx cnx, St
                         readCompacted, initialPosition, keySharedMeta, startMessageId, consumerEpoch);
 
                 return addConsumerToSubscription(subscription, consumer).thenCompose(v -> {
-                    if (subscription instanceof PersistentSubscription persistentSubscription) {
+                    if (subscription instanceof PersistentSubscription) {
+                        PersistentSubscription persistentSubscription = (PersistentSubscription) subscription;
                         checkBackloggedCursor(persistentSubscription);
                     }
                     if (!cnx.isActive()) {