X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fsumup%2Fgateway%2FApplication.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fsumup%2Fgateway%2FApplication.java;h=928a17f99fdb3dddf5113c1bd7fccc93f13eca7e;hb=bf22e88ee5c8ca389df91f6879896e59335c8f2d;hp=abe0685f2a08276be66f2fff8c1a206772bfddde;hpb=9d6c2ef3461546170a0fd9da744efc316b37e1eb;p=demos%2Fkafka%2Fwordcount diff --git a/src/main/java/de/juplo/kafka/sumup/gateway/Application.java b/src/main/java/de/juplo/kafka/sumup/gateway/Application.java index abe0685..928a17f 100644 --- a/src/main/java/de/juplo/kafka/sumup/gateway/Application.java +++ b/src/main/java/de/juplo/kafka/sumup/gateway/Application.java @@ -1,4 +1,4 @@ -package de.juplo.kafka.wordcount.recorder; +package de.juplo.kafka.sumup.gateway; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.ProducerConfig; @@ -13,11 +13,11 @@ import java.util.Properties; @SpringBootApplication -@EnableConfigurationProperties(RecorderApplicationProperties.class) -public class RecorderApplication +@EnableConfigurationProperties(ApplicationProperties.class) +public class Application { @Bean(destroyMethod = "close") - KafkaProducer producer(RecorderApplicationProperties properties) + KafkaProducer producer(ApplicationProperties properties) { Assert.hasText(properties.getBootstrapServer(), "juplo.wordcount.recorder.bootstrap-server must be set"); @@ -31,6 +31,6 @@ public class RecorderApplication public static void main(String[] args) { - SpringApplication.run(RecorderApplication.class, args); + SpringApplication.run(Application.class, args); } }