《ApachePulsar从入门到实战》系列教程第5讲之JavaApi操作Pulsar

一、基于pulsar实现topic的构建操作，准备工作

首先，需要我们创建一个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