Technoboy- opened a new pull request, #17236: URL: https://github.com/apache/pulsar/pull/17236
Fixes #17086 Master Issue: #17086 ### Motivation #7883 supports topic-level offload, when it sets the policy, it calls `internalUpdateOffloadPolicies` to update the topic that the current broker owns. But `pulsar().getBrokerService().getTopicIfExist` will check the topic ownership first, so it may throw the below exception that #17086 occurs. ``` org.apache.pulsar.broker.service.BrokerServiceException$ServiceUnitNotReadyException: Namespace bundle for topic (persistent://ys/ys1/topic1-partition-1) not served by this instance. Please redo the lookup. Request is denied: namespace=ys/ys1 ``` As #11051 has changed that `Redirect to the broker which is the owner of the partition-0 for a partitioned topic when setting topic policy`, we'd better keep the same behavior for updating the topic policy. So remove `internalUpdateOffloadPolicies` method. ### Documentation - [x] `doc-not-needed` (Please explain why) -- 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]
