java查看rocketmq的所有Topic
时间: 2023-07-06 15:39:09 浏览: 226
要查看RocketMQ中的所有Topic,可以使用RocketMQ提供的Admin API。下面是Java代码示例:
```java
import org.apache.rocketmq.common.admin.TopicStatsTable;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
public class ListTopics {
public static void main(String[] args) throws Exception {
// 创建DefaultMQAdminExt对象
DefaultMQAdminExt admin = new DefaultMQAdminExt();
// 设置NameServer地址
admin.setNamesrvAddr("localhost:9876");
// 启动对象
admin.start();
// 获取Topic的统计信息
TopicStatsTable topicStatsTable = admin.examineTopicStats();
// 遍历Topic,输出Topic名称
for (String topic : topicStatsTable.getOffsetTable().keySet()) {
System.out.println(topic);
}
// 关闭对象
admin.shutdown();
}
}
```
这段代码使用DefaultMQAdminExt对象连接到RocketMQ的NameServer,获取Topic的统计信息,然后遍历Topic并输出名称。
阅读全文