You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/06/01 04:08:40 UTC

[GitHub] [pulsar] wuzhanpeng commented on a change in pull request #10707: force to refresh partition metadata info

wuzhanpeng commented on a change in pull request #10707:
URL: https://github.com/apache/pulsar/pull/10707#discussion_r642767763



##########
File path: pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
##########
@@ -2290,7 +2290,7 @@ private void createPendingLoadTopic() {
     public CompletableFuture<PartitionedTopicMetadata> fetchPartitionedTopicMetadataAsync(TopicName topicName) {
         // gets the number of partitions from the configuration cache
         return pulsar.getPulsarResources().getNamespaceResources().getPartitionedTopicResources()
-                .getAsync(partitionedTopicPath(topicName)).thenApply(metadata -> {

Review comment:
       So should we invalidate the path at the end of the delete operation instead of replacing with an Optional.empty() ?




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org