heesung-sn commented on issue #24057: URL: https://github.com/apache/pulsar/issues/24057#issuecomment-2741480688
BrokerRegistryImpl uses `MetadataCache<BrokerLookupData> brokerLookupDataMetadataCache; `. I think the session events are handled at AbstractMetadataStore and MetadataStore Implementations(e.g. ZKMetadataStore). The behavior seems to be 1 "watch again(if sessions are reestablished) and 2. invalidate the metadata cache(hence the next lookup should fetch broker registries from the metadata store) ref: https://github.com/apache/pulsar/blob/master/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java#L497-L522 https://github.com/apache/pulsar/blob/master/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java#L149-L174 -- 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: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
