当无法连接到Kafka时强制Spring Boot应用程序失败

Question

我想让我的 Spring 启动应用程序在启动时失败，如果它无法连接到 kafka 代理。我的应用程序仅向主题发布消息。我将这一行添加到我的属性文件中，但到目前为止没有运气spring.kafka.admin.fail-fast=true。

Answer 1

快速失败只有在上下文中至少有一个NewTopicbean时才会起作用（因此管理员将尝试检查主题是否存在，如果不存在则创建它）。

@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

Answer 2

关于如何加速快速失败的补充

TL；Spring Boot博士2.4.5自动配置不允许您使用环境参数加速故障快速。将此添加到您的@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;
}

更详细的答案

当＜code＞org.springframework.kafka.core类的＜code＞initialize（）＜/code＞方法时，会发生快速失败。执行KafkaAdmin。此方法可能会阻止：

1. 如果发现新主题，它会阻止主题创建，最多操作超时
   1. 如果主题创建失败，它会阻止释放最多CloseTimeout
   的资源

   默认情况下，这些值相应地为30秒和10秒（在上面提到的类中硬编码）。您可以使用set方法重新定义它们：set操作超时（int sec），setCloseTimeout（int sec）。

   Spring的靴子呢？KafkaAdmin bean 是在 class 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;
   }