pulsar-admin接入项目

练手项目

第一步：添加依赖

<dependency>
  <groupId>org.apache.pulsar</groupId>
  <artifactId>pulsar-client-admin</artifactId>
  <version>2.10.1</version>
</dependency>

第二步：编写代码

String token = "你的token";

PulsarAdmin admin = PulsarAdmin.builder()
    .serviceHttpUrl(你的url)
    .authentication(AuthenticationFactory.token(token))
    .build();
// 获取分区列表    
// Topics topics = admin.topics();
// System.out.println(topics.getList("tenant/namespace"));
// admin.close();
// 计算分区tipic 分区0的消息堆积量
TopicStats topicStats = admin.topics().getStats("persistent://tenant/namespace/你的topic-partition-0");
System.out.println(topicStats.getStorageSize());
admin.close();