shibd commented on a change in pull request #13337:
URL: https://github.com/apache/pulsar/pull/13337#discussion_r774844622
##########
File path:
pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java
##########
@@ -200,6 +200,20 @@ public TopicPolicies getTopicPolicies(TopicName topicName,
:
policiesCache.get(TopicName.get(topicName.getPartitionedTopicName()));
}
+ @Override
+ public CompletableFuture<Void> removeTopicPoliciesCache(TopicName
topicName) {
+ NamespaceName namespace = topicName.getNamespaceObject();
+ CompletableFuture<SystemTopicClient.Reader<PulsarEvent>>
readerCompletableFuture =
Review comment:
@Technoboy- Hi, Just closing the reader doesn't seem to work.
Have some producer will still be reconnection(Then the trigger topic is auto
created again), May be also should closed all writer?
And can only do it closed the readers/writers on the current broker.
Essential reason, When close Pulsar client, Broker send to client
`CLOSE_PRODUCER `, When the producer client receives the `CLOSE_PRODUCER`, it
will reconnecting, Then the trigger topic is auto created again.
Should we add new commands? When the client receives the command, it only
closes without reconnecting.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
