如何阻止Spring初始化上下文后关闭上下文？Kafka监听应用场景

看起来你碰到了Spring Boot Kafka应用启动后自动退出的问题，这在手动用ApplicationRunner处理消费逻辑时很常见——因为Spring Boot在执行完ApplicationRunner的run方法后，没有活跃的非守护线程维持应用运行，就会自动关闭上下文。下面给你两种解决思路，优先推荐第一种更简洁的官方方案：

方案一：改用Spring Kafka注解式消费者（推荐） #

Spring Kafka提供了@KafkaListener注解，框架会自动帮你创建并维护消费者线程，这些线程是活跃的非守护线程，能让应用持续运行，同时还能帮你处理消费者的生命周期、重试等细节，比手动写消费逻辑省心多了。

步骤： #

1. 保留你的基础Spring Boot启动类，去掉ApplicationRunner相关代码：

package pkg;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Application {

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

2. 创建一个独立的消费者组件，用@KafkaListener指定要监听的主题和消费组：

package pkg;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class KafkaMessageListener {

    private static final Logger logger = LoggerFactory.getLogger(KafkaMessageListener.class);

    // 替换成你的主题名和消费组ID
    @KafkaListener(topics = "your-target-topic", groupId = "your-consumer-group")
    public void handleReceivedMessage(String message) {
        logger.info("Received Kafka message: {}", message);
    }
}

启动应用后，Spring会自动初始化Kafka消费者线程，应用就会一直运行并监听消息了。

方案二：如果必须用ApplicationRunner，手动阻塞应用 #

如果你因为某些原因一定要用ApplicationRunner手动处理消费逻辑，可以通过阻塞主线程的方式阻止应用关闭。比如用CountDownLatch来实现：

修改你的Application类：

package pkg;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import java.util.concurrent.CountDownLatch;

@SpringBootApplication
public class Application {

    private static final Logger logger = LoggerFactory.getLogger(Application.class);
    // 用CountDownLatch来阻塞主线程
    private final CountDownLatch keepAliveLatch = new CountDownLatch(1);

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

    @Bean
    public ApplicationRunner applicationRunner() {
        return args -> {
            // 这里写你的手动Kafka消费逻辑，比如创建消费者、循环拉取消息等
            logger.info("Starting manual Kafka listener...");
            
            // 阻塞主线程，直到latch被计数（比如收到停止信号时调用keepAliveLatch.countDown()）
            keepAliveLatch.await();
        };
    }
}

不过这种方式需要你自己管理消费者的启动、关闭、异常处理等，不如注解式方案优雅，所以优先推荐第一种。

内容的提问来源于stack exchange，提问作者Artem Petrov