Kafka离线时Spring无法启动

在 Spring 配置文件中进行如下设置，以处理 Kafka 离线时的异常：

@Bean
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    if (isKafkaRunning()) {
        factory.setConsumerFactory(consumerFactory());
    }
    factory.getContainerProperties().setPollTimeout(3000);
    return factory;
}

private boolean isKafkaRunning() {
    try (Socket s = new Socket(KAFKA_SERVER, KAFKA_PORT)) {
        return true;    
    } catch (IOException e) {
        return false;
    }
}

其中，isKafkaRunning() 方法用于检测 Kafka 是否运行，如果运行则返回 true，否则返回 false。如果 Kafka 离线，则 kafkaListenerContainerFactory() 方法会跳过设置 consumerFactory()，避免启动异常。