首先,需要我们创建一个maven项目,并加入pulsar相关依赖
二、租户、命名空间、topic相关api操作 //创建pulsar admin
String serviceHttpUrl = "http://node1:8080,node2:8080,node3:8080";
PulsarAdmin pulsarAdmin = PulsarAdmin.builder().serviceHttpUrl(serviceHttpUrl).build();
//***************************租户相关api操作*********************************************
//创建租户
HashSet allowedClusters = Sets.newHashSet("pulsar-cluster");
TenantInfo tenantInfo = TenantInfo.builder().allowedClusters(allowedClusters).build();
pulsarAdmin.tenants().createTenant("dzx_tenan 


