无活跃Kafka监听器时Spring Boot应用意外关闭问题求解

问题根源在于：Spring Boot应用会在没有非守护线程运行时自动关闭。你的应用没有集成spring-boot-web-starter（无Web容器常驻线程），且Kafka监听器设置autoStartUp=false后，未启动对应的消费者线程（默认是守护线程），因此应用启动完成后就会触发关闭流程。

下面是两种可靠的解决方法：

方法一：添加常驻非守护线程（推荐） #

通过注册ApplicationRunner，在应用启动后让一个线程保持等待，直到收到关闭信号。这种方式既能保持应用运行，又能响应正常的关闭事件（比如Ctrl+C或容器停止指令）。

示例代码：

import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.context.event.ContextClosedEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
import java.util.concurrent.CountDownLatch;

@Component
public class AppKeepAliveHandler {

    private final CountDownLatch shutdownLatch = new CountDownLatch(1);

    @EventListener(ContextClosedEvent.class)
    public void onAppShutdown(ContextClosedEvent event) {
        // 收到关闭事件时，释放latch，让等待线程退出
        shutdownLatch.countDown();
    }

    @Bean
    public ApplicationRunner keepAliveRunner() {
        return args -> {
            // 让线程一直等待，直到latch被释放
            shutdownLatch.await();
        };
    }
}

方法二：修改Kafka消费者线程为非守护线程 #

默认情况下，Spring Kafka创建的消费者线程是守护线程。你可以修改ConsumerFactory的配置，将线程设置为非守护线程，这样即使监听器初始不启动，只要容器初始化完成，就会有非守护线程存在（注意：部分场景下容器初始化可能不会提前创建线程，此方法通用性弱于方法一）。

示例代码：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.core.ConsumerFactory;
import java.util.HashMap;
import java.util.Map;

@Configuration
public class KafkaConfig {

    @Bean
    public ConsumerFactory<String, Object> consumerFactory() {
        Map<String, Object> configProps = new HashMap<>();
        // 配置Kafka连接信息
        configProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "your-kafka-servers");
        configProps.put(ConsumerConfig.GROUP_ID_CONFIG, "your-group-id");
        // 其他必要配置...

        DefaultKafkaConsumerFactory<String, Object> factory = new DefaultKafkaConsumerFactory<>(configProps);
        // 将消费者线程设置为非守护线程
        factory.setDaemon(false);
        return factory;
    }
}

注意事项 #

• 方法一通用性更强，适用于所有无常驻线程的Spring Boot非Web应用场景；
• 方法一不会影响你原有动态启停Kafka监听器的逻辑，依然可以通过KafkaListenerEndpointRegistry执行暂停/恢复操作；
• 确保应用关闭时能正常触发ContextClosedEvent，比如使用SpringApplication.exit()或容器停止指令，避免强制杀死进程导致资源泄漏。

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