Блог

Я хочу, чтобы мое приложение spring boot завершалось сбоем при запуске, если оно не может подключиться к брокеру kafka. Мое приложение публикует сообщения только в разделах. Я добавил эту строку в свой файл свойств, но пока безуспешно spring.kafka.admin.fail-fast=true .

Дополнение о том, как ускорить сбой

TL; DR Автоматическая настройка Spring Boot 2.4.5 не позволяет ускорить отказоустойчивость с помощью параметров env. Добавьте это в свой @Configuration, чтобы получить 10-секундный тайм-аут:

 @Bean
public KafkaAdmin kafkaAdmin(@Autowired KafkaProperties properties) {
    KafkaAdmin kafkaAdmin = new KafkaAdmin(properties.buildAdminProperties());
    kafkaAdmin.setFatalIfBrokerNotAvailable(properties.getAdmin().isFailFast());

    /* speed up fail fast */
    kafkaAdmin.setOperationTimeout(5);
    kafkaAdmin.setCloseTimeout(5);

    return kafkaAdmin;
}
  

Более подробный ответ

При выполнении initialize() метода класса org.springframework.kafka.core.KafkaAdmin происходит быстрый сбой. Этот метод может блокировать:

1. При обнаружении новых тем создание темы блокируется на срок до operationTimeout
   1. Если не удалось создать раздел, он блокирует освобождение ресурсов на срок до closeTimeout

По умолчанию эти значения равны 30 и 10 секундам соответственно (жестко заданы в классе, упомянутом выше). Вы можете переопределить их, используя установленные методы: setOperationTimeout(int sec) , setCloseTimeout(int sec) .

Как насчет Spring Boot? KafkaAdmin компонент создается в классе org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration . Как вы можете догадаться, Spring Boot просто не устанавливает тайм-ауты:

 @Bean
@ConditionalOnMissingBean
public KafkaAdmin kafkaAdmin() {
    KafkaAdmin kafkaAdmin = new KafkaAdmin(this.properties.buildAdminProperties());
    kafkaAdmin.setFatalIfBrokerNotAvailable(this.properties.getAdmin().isFailFast());
    return kafkaAdmin;
}
  

fail-fast будет работать, только если в контексте есть хотя бы один NewTopic компонент (поэтому администратор попытается проверить, существует ли тема, и создать ее, если нет).

 @SpringBootApplication
public class So55177700Application {

    public static void main(String[] args) {
        SpringApplication.run(So55177700Application.class, args);
    }

    @Bean
    public NewTopic topic() {
        return new NewTopic("so55177700", 1, (short) 1);
    }

}

Error starting ApplicationContext. To display the conditions report re-run your application with 'debug' enabled.
2019-03-15 09:42:49.555 ERROR 41793 --- [           main] o.s.boot.SpringApplication               : Application run failed

java.lang.IllegalStateException: Could not configure topics