Skip to content

Commit

Permalink
[improve][broker] Remove spamming logs for customized managed ledger (#…
Browse files Browse the repository at this point in the history
…23862)

(cherry picked from commit a93e93d)
  • Loading branch information
BewareMyPower authored and lhotari committed Jan 20, 2025
1 parent e6cd85c commit cae9f60
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3237,8 +3237,8 @@ public CompletableFuture<Void> 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())) {
Expand Down

0 comments on commit cae9f60

Please sign in to comment.