Please update the codebase for Pulsar 2.9. I observe there are dependencies on PulsarService::getLocalZkCache (which was removed in 2.9).
The topic lookup aspect seems in need of improvement. Be aware that most ZK structures use the broker's canonical name as the key, which is based on that broker's advertisedAddress:webServicePort. This is not the same as the broker service URL that is returned from the LookupService. The lookup service returns information from advertisedListeners which isn't necessarily the same value.
Related:
Please update the codebase for Pulsar 2.9. I observe there are dependencies on
PulsarService::getLocalZkCache(which was removed in 2.9).The topic lookup aspect seems in need of improvement. Be aware that most ZK structures use the broker's canonical name as the key, which is based on that broker's
advertisedAddress:webServicePort. This is not the same as the broker service URL that is returned from theLookupService. The lookup service returns information fromadvertisedListenerswhich isn't necessarily the same value.Related: