X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FQueryApplicationConfiguration.java;h=9f6769f3d00d63125b59a57e4036535f2af3ef65;hb=6c5e42de43030ce2e5d63be537d8d5a371369a8b;hp=813d3b28212acc5b059c2ae4df41b8f45fc535fa;hpb=8681e52b8be6c2970bb229888da6e92260bcef47;p=demos%2Fkafka%2Fwordcount diff --git a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java index 813d3b2..9f6769f 100644 --- a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java @@ -2,33 +2,32 @@ package de.juplo.kafka.wordcount.query; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.kafka.streams.state.HostInfo; -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.web.ServerProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; import java.io.IOException; import java.net.InetSocketAddress; import java.net.Socket; -@SpringBootApplication +@Configuration @EnableConfigurationProperties(QueryApplicationProperties.class) -public class QueryApplication +public class QueryApplicationConfiguration { @Bean - public QueryStreamProcessor usersStreamProcessor( + public QueryStreamProcessor streamProcessor( ServerProperties serverProperties, - QueryApplicationProperties properties, + QueryApplicationProperties applicationProperties, ObjectMapper mapper, ConfigurableApplicationContext context) throws IOException { String host; if (serverProperties.getAddress() == null) { - HostInfo bootstrapServer = HostInfo.buildFromEndpoint(properties.getBootstrapServer()); + HostInfo bootstrapServer = HostInfo.buildFromEndpoint(applicationProperties.getBootstrapServer()); Socket socket = new Socket(); socket.connect(new InetSocketAddress(bootstrapServer.host(), bootstrapServer.port())); host = socket.getLocalAddress().getHostAddress(); @@ -41,18 +40,12 @@ public class QueryApplication Integer port = serverProperties.getPort() == null ? 8080 : serverProperties.getPort(); return new QueryStreamProcessor( - properties.getApplicationId(), + applicationProperties.getApplicationId(), new HostInfo(host, port), - properties.getBootstrapServer(), - properties.getUsersInputTopic(), - properties.getRankingInputTopic(), + applicationProperties.getBootstrapServer(), + applicationProperties.getUsersInputTopic(), + applicationProperties.getRankingInputTopic(), mapper, context); } - - - public static void main(String[] args) - { - SpringApplication.run(QueryApplication.class, args); - } }