WIP

[demos/kafka/wordcount] / src / main / java / de / juplo / kafka / sumup / gateway / Application.java

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 (file)
--- 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<String, String> producer(RecorderApplicationProperties properties)
+       KafkaProducer<String, String> 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);
        }
 }