[improve][pulsar] Removed checkBackloggedCursors() from subscribe

heesung-sn · Jan 28, 2023 · 1df04c6 · 1df04c6
1 parent 71cedd7
commit 1df04c6
Showing 1 changed file with 0 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
@@ -812,7 +812,6 @@ private CompletableFuture<Consumer> internalSubscribe(final TransportCnx cnx, St
                         readCompacted, keySharedMeta, startMessageId, consumerEpoch);
 
                 return addConsumerToSubscription(subscription, consumer).thenCompose(v -> {
-                    checkBackloggedCursors();
                     if (!cnx.isActive()) {
                         try {
                             consumer.close();