以编程方式查找kafka主题大小

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.ListTopicsResult;
import org.apache.kafka.clients.admin.TopicDescription;
import org.apache.kafka.common.KafkaFuture;
import org.apache.kafka.common.TopicPartitionInfo;

import java.util.Properties;
import java.util.concurrent.ExecutionException;

Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "kafka服务器地址");

AdminClient adminClient = AdminClient.create(props);

ListTopicsResult topicsResult = adminClient.listTopics();
KafkaFuture<Set<String>> topicNamesFuture = topicsResult.names();
Set<String> topicNames = topicNamesFuture.get();

for (String topicName : topicNames) {
    KafkaFuture<TopicDescription> topicDescriptionFuture = adminClient.describeTopics(Collections.singleton(topicName)).values().get(topicName);
    TopicDescription topicDescription = topicDescriptionFuture.get();
    
    // 获取主题分区信息
    List<TopicPartitionInfo> partitions = topicDescription.partitions();
    
    // 计算主题大小
    long topicSize = partitions.stream()
            .mapToLong(partition -> partition.sizeInBytes())
            .sum();
    
    System.out.println("主题：" + topicName + "，大小：" + topicSize + "字节");
}