WIP

[demos/kafka/outbox] / src / main / java / de / trion / kafka / outbox / Application.java

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 (file)
--- 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);
     }