Kafka+查询所有Topic的详细配置

我们可以使用Kafka的AdminClient API来查询所有Topic的详细配置。首先需要创建一个AdminClient实例，然后使用其describeTopics方法来查询Topic的详细配置。

下面是一个示例代码：

import java.util.*;
import org.apache.kafka.clients.admin.*;
import org.apache.kafka.clients.consumer.*;
import org.apache.kafka.common.*;
import org.apache.kafka.common.config.*;
 
public class KafkaTopicConfigExample {
 
    public static void main(String[] args) throws Exception {
        String bootstrapServers = "localhost:9092";
        
        // 创建AdminClient实例
        Properties props = new Properties();
        props.setProperty(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        AdminClient adminClient = AdminClient.create(props);
 
        // 查询所有Topic的详细配置
        ListTopicsResult listTopicsResult = adminClient.listTopics();
        Set<String> topicNames = listTopicsResult.names().get();
        Map<String, TopicDescription> topicDescriptions = adminClient.describeTopics(topicNames).all().get();
        for (Map.Entry<String, TopicDescription> entry : topicDescriptions.entrySet()) {
            String topicName = entry.getKey();
            TopicDescription topicDescription = entry.getValue();
            System.out.println("Topic: " + topicName);
            System.out.println("Configurations:");
            Map<String, String> configs = topicDescription.configs().entrySet().stream()
                    .collect(Collectors.toMap(e -> e.getKey(), e -> e.getValue().value()));
            configs.forEach((k, v) -> System.out.println("\t" + k + "=" + v));
        }
        
        // 关闭AdminClient实例
        adminClient.close();
    }
 
}

运行以上示例代码，可以查询到所有Topic的详细配置。其中configs变量包含了Topic的所有配置项，可以根据需要进行解析和处理。