如果kafka中不存在属性中的kafka主题名称，如何中断启动spring-boot应用程序？

Question

我尝试在启动spring-boot应用程序上检查Kafka主题。我想抛出异常并中断启动。这是我的配置：

@Slf4j
@Configuration
public class KafkaTopicConfig implements ApplicationRunner {

    private final KafkaAdmin kafkaAdmin;
    private final TopicProperties topicProperties;

    public KafkaTopicConfig(KafkaAdmin kafkaAdmin, TopicProperties topicProperties) {
        this.kafkaAdmin = kafkaAdmin;
        this.topicProperties = topicProperties;
    }

    @Override
    public void run(ApplicationArguments args) throws Exception {
        AdminClient admin = AdminClient.create(kafkaAdmin.getConfig());

        ListTopicsResult listTopicsResult = admin.listTopics();
        listTopicsResult.names().whenComplete((existTopics, throwable) -> {
            log.info("TOPICS LOAD: {}", existTopics.size());
            topicProperties.getTopics().forEach((s, topic) -> {
                if (!existTopics.contains(topic))
                    throw new IllegalStateException("Topic with name: " + topic + " not found in kafka.");
            });
        });
    }
}

但抛出throw new IllegalStateException("Topic with name: " + topic + " not found in kafka.");后，这个异常被忽略，应用程序继续工作。

Answer 1

而不是ApplicationRunner，用SmartLifecycle实现autoStartup=true并将你的逻辑放在start()中。