java查看rocketmq Topic

您可以使用 RocketMQ 的 Admin API 来查看特定 Topic 的信息。以下是使用 Java 代码调用 Admin API 查看特定 Topic 的示例：

import org.apache.rocketmq.common.admin.TopicStatsTable;
import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;

public class ViewTopic {
    public static void main(String[] args) throws Exception {
        String topicName = "your_topic_name"; // 指定要查看的 Topic 名称
        DefaultMQAdminExt admin = new DefaultMQAdminExt();
        admin.start();
        TopicStatsTable topicStatsTable = admin.examineTopicStats(topicName);
        System.out.println(topicStatsTable.toString());
        admin.shutdown();
    }
}

在该示例中，我们创建了一个 `DefaultMQAdminExt` 对象，然后调用 `start()` 方法启动它。接着，我们指定要查看的 Topic 名称，并调用 `examineTopicStats(String topic)` 方法来获取该 Topic 的统计信息。最后，我们输出该 Topic 的统计信息，并调用 `shutdown()` 方法关闭 `DefaultMQAdminExt` 对象。