kafka2.4.1 获取 Topic数据大小，java代码

您好，可以通过调用 KafkaAdminClient 的 describeTopics() 方法获取 Topic 数据大小，示例代码如下：

Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
KafkaAdminClient adminClient = (KafkaAdminClient) KafkaAdminClient.create(props);
Map<String, TopicDescription> topicDescriptions = adminClient.describeTopics(Collections.singletonList("your-topic")).all().get();
for (Map.Entry<String, TopicDescription> entry : topicDescriptions.entrySet()) {
    TopicDescription topicDescription = entry.getValue();
    long dataSize = topicDescription.partitions().stream().mapToLong(p -> p.partitionSize()).sum();
    System.out.println("The size of topic " + topicDescription.name() + " is " + dataSize);
}

希望能对您有所帮助，谢谢！