Allow to connect to Pulsar cluster with non-admin tokens

This commit is contained in:
Enrico Olivelli 2022-01-29 17:03:37 +01:00
parent 3b184a0c23
commit 5064ab3493

View File

@ -76,9 +76,9 @@ public class PulsarSpace {
CollectionUtils.addAll(pulsarClusterMetadata, stringList.listIterator());
} catch (PulsarAdminException e) {
String errMsg = "Fail to create PulsarClient from global configuration: " + e.getMessage();
logger.error(errMsg);
throw new RuntimeException(errMsg);
// this is okay if you are connecting with a token that does not have access to the
// system configuration
logger.info("Could not get list of Pulsar Clusters from global configuration: " + e.getMessage());
}
}