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
…pache#23862)

(cherry picked from commit a93e93d)
(cherry picked from commit cae9f60)
  • Loading branch information
BewareMyPower authored and nikhil-ctds committed Jan 31, 2025
1 parent eea9df4 commit a06f336
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3243,8 +3243,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 a06f336

Please sign in to comment.