我在 Spring Boot 中配置了幾個(gè) Kafka 消費(fèi)者。這就是 kafka.properties 的樣子（這里只列出一個(gè)消費(fèi)者的配置）：kafka.topics=bootstrap.servers=group.id=enable.auto.commit=auto.commit.interval.ms=session.timeout.ms=schema.registry.url=auto.offset.reset=kafka.enabled=這是配置：@Configuration@PropertySource({"classpath:kafka.properties"})public class KafkaConsumerConfig {    @Autowired    private Environment env;    @Bean    public ConsumerFactory<String, String> pindropConsumerFactory() {        Map<String, Object> dataRiverProps = new HashMap<>();        dataRiverProps.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, env.getProperty("bootstrap.servers"));        dataRiverProps.put(ConsumerConfig.GROUP_ID_CONFIG, env.getProperty("group.id"));        dataRiverProps.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, env.getProperty("enable.auto.commit"));        dataRiverProps.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, env.getProperty("auto.commit.interval.ms"));        dataRiverProps.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, env.getProperty("session.timeout.ms"));        dataRiverProps.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());        dataRiverProps.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());        dataRiverProps.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, env.getProperty("auto.offset.reset"));        return new DefaultKafkaConsumerFactory<>(dataRiverProps);    }    @Bean    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory() {        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();        factory.setConsumerFactory(pindropConsumerFactory());        return factory;    }}有沒有辦法讓我使用道具“kafka.enabled”，這樣我就可以控制這個(gè)消費(fèi)者的創(chuàng)建或者消息檢索？非常感謝！