X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Ftrion%2Fkafka%2Foutbox%2FApplication.java;h=f6865f5f6d68e5329d742c535ebf9bfdd5baa7e3;hb=900c3e78da3cc0bbf103c67f00243af1890826a9;hp=878e75ec21a8e50e1489aaca65c37bd3d376d490;hpb=9c9203a9f0acd4e0e8665cb7d7a2bc36fb4e80c7;p=demos%2Fkafka%2Foutbox diff --git a/src/main/java/de/trion/kafka/outbox/Application.java b/src/main/java/de/trion/kafka/outbox/Application.java index 878e75e..f6865f5 100644 --- a/src/main/java/de/trion/kafka/outbox/Application.java +++ b/src/main/java/de/trion/kafka/outbox/Application.java @@ -2,51 +2,15 @@ package de.trion.kafka.outbox; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.boot.context.properties.EnableConfigurationProperties; -import org.springframework.context.annotation.Bean; -import org.springframework.web.servlet.config.annotation.CorsRegistry; -import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; @SpringBootApplication -@EnableConfigurationProperties(ApplicationProperties.class) public class Application { private final static Logger LOG = LoggerFactory.getLogger(Application.class); - @Autowired - ApplicationProperties properties; - - - @Bean - public String bootstrapServers() { return properties.bootstrapServers; } - - @Bean - public String topic() { - return properties.topic; - } - - @Bean - public String consumerGroup() { - return properties.consumerGroup; - } - - @Bean - public WebMvcConfigurer corsConfigurer() { - return new WebMvcConfigurer() { - @Override - public void addCorsMappings(CorsRegistry registry) { - registry - .addMapping("/**") - .allowedOrigins("http://localhost:4200"); - } - }; - } - - public static void main(String[] args) { SpringApplication.run(Application.class, args); }