@RefreshScope配置下Kafka Producer未重建导致旧实例持续告警问题

• @RefreshScope 刷新时只会销毁Spring容器管理的Bean对象，Kafka Producer内部自带的元数据重试、IO后台线程不受Spring生命周期管理，如果旧Producer没有显式调用close()方法，这些线程会一直持有旧的bootstrap.servers配置持续重试连接，就是你看到的producer-1持续告警的核心原因
• 你之前调用DefaultKafkaConsumerFactory的销毁/重置方法不生效，是因为该类只负责消费者实例管理，和生产者完全无关，自然不会清理旧的Producer资源

方案1：给自定义Kafka Bean加销毁逻辑 #

在你的MyKafkaBean中显式声明销毁方法，实例被Spring销毁时主动关闭内部持有的Producer实例，释放所有后台线程资源：

public class MyKafkaBean implements DisposableBean {
    // 你内部持有的Producer实例
    private KafkaProducer<?, ?> kafkaProducer;
    // 你内部持有的Consumer实例
    private KafkaConsumer<?, ?> kafkaConsumer;

    // 原有业务逻辑代码不变

    @Override
    public void destroy() throws Exception {
        // 关闭生产者，最多等待3秒完成资源回收
        if (kafkaProducer != null) {
            kafkaProducer.close(Duration.ofSeconds(3));
        }
        // 消费者也可补充关闭逻辑，保证资源完全释放
        if (kafkaConsumer != null) {
            kafkaConsumer.close(Duration.ofSeconds(3));
        }
    }
}

配置刷新时Spring会先销毁旧的@RefreshScope修饰的MyKafkaBean实例，自动触发destroy方法清理旧Producer的后台线程，再创建持有新配置的新实例，不会再有残留的告警。

方案2：使用Spring Kafka自带ProducerFactory时的补充处理 #

如果你是通过DefaultKafkaProducerFactory创建Producer，除了上述销毁逻辑外，还需要在配置刷新时手动调用工厂的重置方法清理内部缓存的Producer实例：

@Autowired
private DefaultKafkaProducerFactory<?, ?> producerFactory;

// 配置刷新事件监听，自动重置Producer缓存
@EventListener
public void onRefresh(RefreshScopeRefreshedEvent event) {
    producerFactory.reset();
}

• 不要在自定义工具类、静态变量中额外缓存Producer实例，避免Spring销毁Bean后还有残留引用导致资源无法释放
• Kafka Producer的close方法建议指定超时时间，避免阻塞Spring的Bean销毁流程

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