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 2fd0347c41f7b..0f6a6db2cd299 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 @@ -3243,8 +3243,8 @@ public CompletableFuture updateOldPositionInfo() { TopicName topicName = TopicName.get(getName()); if (!(ledger.getCursors() instanceof ManagedCursorContainer managedCursorContainer)) { - return CompletableFuture.failedFuture(new IllegalStateException( - String.format("[%s] No valid cursors found. Skip update old position info.", topicName))); + // TODO: support this method with a customized managed ledger implementation + return CompletableFuture.completedFuture(null); } if (!hasBacklogs(brokerService.pulsar().getConfiguration().isPreciseTimeBasedBacklogQuotaCheck())) {