1 package de.trion.kafka.outbox;
3 import org.springframework.beans.factory.annotation.Autowired;
4 import org.springframework.boot.SpringApplication;
5 import org.springframework.boot.autoconfigure.SpringBootApplication;
6 import org.springframework.boot.context.properties.EnableConfigurationProperties;
7 import org.springframework.context.annotation.Bean;
8 import org.springframework.web.servlet.config.annotation.CorsRegistry;
9 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
11 @SpringBootApplication
12 @EnableConfigurationProperties(ApplicationProperties.class)
13 public class Application {
16 ApplicationProperties properties;
20 public String bootstrapServers() { return properties.bootstrapServers; }
23 public String topic() {
24 return properties.topic;
28 public String consumerGroup() {
29 return properties.consumerGroup;
33 public WebMvcConfigurer corsConfigurer() {
34 return new WebMvcConfigurer() {
36 public void addCorsMappings(CorsRegistry registry) {
39 .allowedOrigins("http://localhost:4200");
45 public static void main(String[] args) {
46 SpringApplication.run(Application.class, args);