获取正在运行的Kafka集群上的所有属性？

kafka-configs.sh --bootstrap-server <kafka-bootstrap-server> --describe --all

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.DescribeConfigsResult;
import org.apache.kafka.clients.admin.ListTopicsResult;
import org.apache.kafka.clients.admin.TopicDescription;
import org.apache.kafka.common.config.ConfigResource;
import org.apache.kafka.common.errors.TimeoutException;

import java.util.Collection;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

public class KafkaClusterProperties {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "<kafka-bootstrap-servers>");

        try (AdminClient adminClient = AdminClient.create(props)) {
            // 获取所有topic的描述信息
            ListTopicsResult topicsResult = adminClient.listTopics();
            Map<String, TopicDescription> topics = topicsResult.namesToListings().get();

            // 遍历所有topic，获取每个topic的配置信息
            for (Map.Entry<String, TopicDescription> entry : topics.entrySet()) {
                String topicName = entry.getKey();
                TopicDescription topicDescription = entry.getValue();
                System.out.println("Topic: " + topicName);
                System.out.println("Partition count: " + topicDescription.partitions().size());

                // 获取topic的配置信息
                ConfigResource configResource = new ConfigResource(ConfigResource.Type.TOPIC, topicName);
                DescribeConfigsResult describeConfigsResult = adminClient.describeConfigs(Collections.singleton(configResource));
                Map<ConfigResource, org.apache.kafka.clients.admin.Config> topicConfigs = describeConfigsResult.all().get();

                // 打印topic的配置信息
                for (Map.Entry<ConfigResource, org.apache.kafka.clients.admin.Config> configEntry : topicConfigs.entrySet()) {
                    ConfigResource resource = configEntry.getKey();
                    org.apache.kafka.clients.admin.Config config = configEntry.getValue();
                    System.out.println("Config: " + resource.name());
                    System.out.println("  " + config.entries());
                }
            }
        } catch (ExecutionException | InterruptedException | TimeoutException e) {
            e.printStackTrace();
        }
    }
}