如何通过属性配置禁用Kafka工厂创建的生产者实例

你配置的autoStartup参数不生效是因为该参数是Spring Kafka针对消费者监听容器的专属配置，仅控制消费者端的监听服务是否随应用启动自动运行，和生产者发送逻辑完全无关，因此添加该配置不会影响消息发送行为。

以下是三种可行的禁用方案：

• 方案一：替换为Mock生产者实现无感知禁用
  如果需要完全关闭生产能力、吞掉所有发送请求不报错，可在ProducerFactory初始化时判断开关，当需要禁用时返回绑定空实现生产者的工厂实例，所有发送请求不会发送到Kafka broker：

@Bean
public ProducerFactory<String, Object> producerFactory() {
    Map<String, Object> configs = new HashMap<>();
    // 填入其他kafka基础配置
    boolean producerEnabled = env.getProperty("kafka.producer.enabled", Boolean.class, true);
    if (!producerEnabled) {
        // 若不想引入spring-kafka-test的MockProducer，可自行实现Producer接口编写空实现
        return new DefaultKafkaProducerFactory<>(configs, (topic) -> new MockProducer<>(true, new StringSerializer(), new JsonSerializer<>()));
    }
    return new DefaultKafkaProducerFactory<>(configs);
}

• 方案二：自定义KafkaTemplate实现动态开关控制
  如果需要灵活切换发送能力的开启/关闭状态，可继承KafkaTemplate重写所有send相关方法，在开关关闭时按业务需求返回默认结果或抛出异常：

public class DisableableKafkaTemplate<K, V> extends KafkaTemplate<K, V> {
    @Value("${kafka.producer.enabled:true}")
    private boolean producerEnabled;

    public DisableableKafkaTemplate(ProducerFactory<K, V> producerFactory) {
        super(producerFactory);
    }

    @Override
    public CompletableFuture<SendResult<K, V>> send(String topic, V data) {
        if (!producerEnabled) {
            // 按需选择返回空成功结果或抛出UnsupportedOperationException
            return CompletableFuture.completedFuture(null);
        }
        return super.send(topic, data);
    }

    // 其余send重载方法均按照上述逻辑重写即可
}

• 方案三：排除Kafka自动配置（全功能禁用场景适用）
  如果应用完全不需要使用Kafka的生产者、消费者能力，可直接在启动类排除Kafka自动配置类，框架不会初始化任何Kafka相关组件：

@SpringBootApplication(exclude = {KafkaAutoConfiguration.class})

注意：该方案会同时禁用生产者和消费者功能，若需要保留消费者能力请选择前两种方案

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