projects
/
demos
/
kafka
/
wordcount
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
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;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
@@
-13,11
+13,11
@@
import java.util.Properties;
@SpringBootApplication
@SpringBootApplication
-@EnableConfigurationProperties(
Recorder
ApplicationProperties.class)
-public class
Recorder
Application
+@EnableConfigurationProperties(ApplicationProperties.class)
+public class Application
{
@Bean(destroyMethod = "close")
{
@Bean(destroyMethod = "close")
- KafkaProducer<String, String> producer(
Recorder
ApplicationProperties properties)
+ KafkaProducer<String, String> producer(ApplicationProperties properties)
{
Assert.hasText(properties.getBootstrapServer(), "juplo.wordcount.recorder.bootstrap-server must be set");
{
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)
{
public static void main(String[] args)
{
- SpringApplication.run(
Recorder
Application.class, args);
+ SpringApplication.run(Application.class, args);
}
}
}
}