From 0d4e98533452c04e356141507a10472ff8af6dac Mon Sep 17 00:00:00 2001 From: Heesung Sohn Date: Mon, 30 Jan 2023 10:03:14 -0800 Subject: [PATCH] [fix][broker] fixed the build error for pattern matching variable in lower JVM versions --- .../pulsar/broker/service/persistent/PersistentTopic.java | 3 ++- 1 file changed, 2 insertions(+), 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 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 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()) {