Kafka集群不可用性检测（3个代理）

以下是一个使用Java编写的示例代码，用于检测Kafka集群的可用性（假设有3个代理）：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.DescribeClusterResult;
import org.apache.kafka.clients.admin.ListTopicsResult;
import org.apache.kafka.clients.admin.TopicListing;
import org.apache.kafka.common.KafkaException;

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

public class KafkaClusterAvailabilityCheck {

    public static void main(String[] args) {
        // Kafka集群的地址和端口
        String bootstrapServers = "localhost:9092,localhost:9093,localhost:9094";

        // 创建AdminClient的配置
        Properties properties = new Properties();
        properties.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

        try (AdminClient adminClient = AdminClient.create(properties)) {
            // 检查Kafka集群是否可用
            checkClusterAvailability(adminClient);

            // 获取所有主题列表
            listTopics(adminClient);
        } catch (KafkaException e) {
            System.err.println("Kafka集群不可用: " + e.getMessage());
        }
    }

    private static void checkClusterAvailability(AdminClient adminClient) {
        DescribeClusterResult clusterResult = adminClient.describeCluster();
        try {
            clusterResult.clusterId().get();
            System.out.println("Kafka集群可用");
        } catch (InterruptedException | ExecutionException e) {
            throw new KafkaException("无法连接到Kafka集群", e);
        }
    }

    private static void listTopics(AdminClient adminClient) {
        ListTopicsResult topicsResult = adminClient.listTopics();
        try {
            for (TopicListing topic : topicsResult.listings().get()) {
                System.out.println("主题名称: " + topic.name());
            }
        } catch (InterruptedException | ExecutionException e) {
            throw new KafkaException("无法获取主题列表", e);
        }
    }
}

此示例代码使用了AdminClient类来与Kafka集群进行通信。checkClusterAvailability方法使用describeCluster方法来检查集群的可用性，并通过查看clusterId是否可获取来确定集群是否可用。listTopics方法使用listTopics方法来获取所有主题的列表，并打印出每个主题的名称。

请注意，上述示例代码仅用于演示目的，实际应用中可能需要根据具体需求进行修改和扩展。