Skip to content

Commit

Permalink
move the log
Browse files Browse the repository at this point in the history
  • Loading branch information
mattisonchao committed Dec 26, 2024
1 parent bacc578 commit 646772a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -286,13 +286,13 @@ public CompletableFuture<Optional<TopicPolicies>> getTopicPoliciesAsync(TopicNam
});
policiesFutureHolder.setValue(Pair.of(true, policies));
} else {
log.info("The future of {} has been removed from cache, retry getTopicPolicies again", namespace);
policiesFutureHolder.setValue(Pair.of(false, null));
}
return existingFuture;
});
final var p = policiesFutureHolder.getValue();
if (!p.getLeft()) {
log.info("The future of {} has been removed from cache, retry getTopicPolicies again", namespace);
return getTopicPoliciesAsync(topicName, type);
}
return CompletableFuture.completedFuture(p.getRight());
Expand Down

0 comments on commit 646772a

Please sign in to comment.