Skip to content

Commit

Permalink
[improve][broker] Remove spamming logs for customized managed ledger (a…
Browse files Browse the repository at this point in the history
  • Loading branch information
BewareMyPower authored and poorbarcode committed Jan 23, 2025
1 parent 6400b77 commit dce73f4
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3497,8 +3497,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 dce73f4

Please sign in to comment.