Frühling Boot-Ladeeigenschaften innerhalb yaml Datei Datei

Question

Ich habe eine application.yml-Datei, die im Innern ruft eine Eigenschaft

Datei Wenn in meinem IDE Ausführung (Eclipse) Ich habe kein Problem, aber wenn das Glas in der Konsole ausgeführt wird (mit Java - jar) Es lädt nicht die Eigenschaftendatei, die in der YAML-Datei festgelegt ist. Hier

ist mein application.yml:

apache: 
    kafka: 
    producer: 
     properties: kafka-producer-${application.environment}.properties 
    consumer: 
     properties: kafka-consumer-${application.environment}.properties 

und hier die .properties:

# 
# Apache Kafka Consumer Properties 
## 
bootstrap.servers=XXXX:9092 
group.id=consumers 
enable.auto.commit=true 
auto.commit.interval.ms=1000 
key.deserializer=org.apache.kafka.common.serialization.StringDeserializer 
value.deserializer=org.apache.kafka.common.serialization.StringDeserializer 
session.timeout.ms=300000 
request.timeout.ms=305000 

Ich lade die Eigenschaften wie diese Datei:

@Value("${apache.kafka.producer.properties}") 
    private String kafkaProducerProperties; 

    @Bean 
    public KafkaProducer<String, String> eventProducer() { 

     try { 
      Properties properties = new Properties(); 
      properties.load(this.context.getResource("classpath:" + this.kafkaProducerProperties).getInputStream()); 

      return new KafkaProducer<String, String>(properties); 
     } catch (final IOException exception) { 
      LOG.error("Error loading Kafka producer properties", exception); 
     } 

     return null; 
    } 

in der IDE ausgeführt wird, Die this.kafkaProducerProperties hat den richtigen Wert, während die Ausführung der jar ist n ull.

Was mache ich falsch und warum lädt es direkt in der IDE, aber nicht das Glas?

Answer 1

Bitte versuchen Sie diesen Code

@Bean 
public KafkaProducer<String, String> eventProducer() { 

    try { 
     Properties properties = new Properties(); 
     properties.put("bootstrap.servers","XXXX:9092"); 
     properties.put("group.id","consumers"); 
     properties.put("enable.auto.commit","true"); 
     properties.put("auto.commit.interval.ms","1000"); 
     properties.put("key.deserializer","org.apache.kafka.common.serialization.StringDeserializer"); 
     properties.put("value.deserializer","org.apache.kafka.common.serialization.StringDeserializer"); 
     properties.put("session.timeout.ms","300000"); 
     properties.put("request.timeout.ms","305000"); 

     return new KafkaProducer<String, String>(properties); 
    } catch (final IOException exception) { 
     LOG.error("Error loading Kafka producer properties", exception); 
    } 
    // Avoid return null in your code instead throw an exception 
    throw new IllegalAccessException("Error loading Kafka producer properties"); 
} 

Hardcoding zu vermeiden, können Sie dies auch 1- Fügen Sie diese in Ihrem application.yml

bootstrap.servers: XXXX 
group.id: consumers 
enable.auto.commit: true 
auto.commit.interval.ms: 1000 
key.deserializer: org.apache.kafka.common.serialization.StringDeserializer 
value.deserializer: org.apache.kafka.common.serialization.StringDeserializer 
session.timeout.ms: 300000 
request.timeout.ms: 305000 

2- Fügen Sie diesen Code

@Value("${bootstrap.servers}") 
private String bootstrapServers; 
@Value("${group.id}") 
private String groupId; 
@Value("${enable.auto.commit}") 
private String enableAutoCommit; 
@Value("${auto.commit.interval.ms}") 
private String autoCommit; 
@Value("${key.deserializer}") 
private String keyDeserializer; 
@Value("${value.deserializer}") 
private String valueDeserializer; 
@Value("${session.timeout.ms}") 
private String sessionTimeout; 
@Value("${request.timeout.ms}") 
private String requestTimeout; 

@Bean 
public KafkaProducer<String, String> eventProducer() { 

    try { 
     Properties properties = new Properties(); 
     properties.put("bootstrap.servers",bootstrapServers+"9092"); 
     properties.put("group.id",groupId); 
     properties.put("enable.auto.commit",enableAutoCommit); 
     properties.put("auto.commit.interval.ms",autoCommit); 
     properties.put("key.deserializer",keyDeserializer); 
     properties.put("value.deserializer",valueDeserializer); 
     properties.put("session.timeout.ms",sessionTimeout); 
     properties.put("request.timeout.ms",requestTimeout); 

     return new KafkaProducer<String, String>(properties); 
    } catch (final IOException exception) { 
     LOG.error("Error loading Kafka producer properties", exception); 
    } 
    // Avoid return null in your code instead throw an exception 
    throw new IllegalAccessException("Error loading Kafka producer properties"); 
} 

Hoffe das hilft.