1 package de.juplo.kafka.outbox.polling;
3 import org.slf4j.Logger;
4 import org.slf4j.LoggerFactory;
5 import org.springframework.beans.factory.annotation.Autowired;
6 import org.springframework.boot.SpringApplication;
7 import org.springframework.boot.autoconfigure.SpringBootApplication;
8 import org.springframework.boot.context.properties.EnableConfigurationProperties;
9 import org.springframework.context.annotation.Bean;
10 import org.springframework.web.servlet.config.annotation.CorsRegistry;
11 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
13 @SpringBootApplication
14 @EnableConfigurationProperties(ApplicationProperties.class)
15 public class Application {
17 private final static Logger LOG = LoggerFactory.getLogger(Application.class);
21 ApplicationProperties properties;
25 public String bootstrapServers() { return properties.bootstrapServers; }
28 public String topic() {
29 return properties.topic;
33 public String consumerGroup() {
34 return properties.consumerGroup;
38 public WebMvcConfigurer corsConfigurer() {
39 return new WebMvcConfigurer() {
41 public void addCorsMappings(CorsRegistry registry) {
44 .allowedOrigins("http://localhost:4200");
50 public static void main(String[] args) {
51 SpringApplication.run(Application.class, args);