springboot检查是否与kafka成功连接的代码

在Spring Boot中，你可以使用`KafkaTemplate`来检查与Kafka的连接是否成功。`KafkaTemplate`是一个高级别的API，它提供了与Kafka进行交互的方法。

以下是一个示例代码：

import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;

import java.util.HashMap;
import java.util.Map;

@Component
public class KafkaConnectionChecker {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    public boolean checkKafkaConnection() {
        try {
            // 发送一个测试消息到Kafka
            kafkaTemplate.sendDefault("test-message").get();

            // 如果发送消息成功，则表示与Kafka连接成功
            return true;
        } catch (Exception e) {
            // 发送消息失败，则表示与Kafka连接失败
            return false;
        }
    }
}

在上面的示例中，我们注入了`KafkaTemplate<String, String>`来与Kafka进行交互。在`checkKafkaConnection()`方法中，我们发送了一个测试消息到默认的topic（通过`sendDefault()`方法），并使用`.get()`来等待消息发送完成。

如果发送消息成功，即没有抛出异常，那么就表示与Kafka连接成功。如果发送消息失败，即抛出了异常，那么就表示与Kafka连接失败。

另外，你还可以使用`AdminClient`来检查与Kafka的连接状态。`AdminClient`是一个用于管理和操作Kafka集群的客户端API。以下是一个使用`AdminClient`检查连接状态的示例代码：

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.common.KafkaFuture;

import java.util.Properties;

@Component
public class KafkaConnectionChecker {

    public boolean checkKafkaConnection() {
        Properties props = new Properties();
        props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");

        try (AdminClient adminClient = AdminClient.create(props)) {
            DescribeClusterResult result = adminClient.describeCluster();
            KafkaFuture<Void> future = result.nodes().isEmpty();
            
            // 如果获取Kafka集群节点成功，则表示与Kafka连接成功
            future.get();
            return true;
        } catch (Exception e) {
            // 获取Kafka集群节点失败，则表示与Kafka连接失败
            return false;
        }
    }
}

在上面的示例中，我们创建了一个`AdminClient`对象，并使用`describeCluster()`方法来获取Kafka集群的信息。然后，我们通过检查`result.nodes().isEmpty()`的结果来判断是否成功获取到Kafka集群的节点信息。

如果成功获取Kafka集群节点信息，即没有抛出异常，那么就表示与Kafka连接成功。如果抛出了异常，那么就表示与Kafka连接失败。

通过以上方法，你可以检查与Kafka的连接状态，并根据需要进行相应的处理。