[fix][broker] fixed the build error for pattern matching variable in …

…lower JVM versions (apache#19362)
datastax · Jan 30, 2023 · 0dfbc61 · 0dfbc61
1 parent 0a8a4d6
commit 0dfbc61
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -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()) {