From 48a2949af528e7c2bf40ec212a5d6d0c6bb9e349 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 9 Jun 2024 09:46:54 +0200 Subject: [PATCH] query: 1.0.6 - Refined naming in `QueryApplicationConfiguration` -- streamlined the naming of attributes and parameters --- .../query/QueryApplicationConfiguration.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) 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 2dea239..c7aa03f 100644 --- a/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java +++ b/src/main/java/de/juplo/kafka/wordcount/query/QueryApplicationConfiguration.java @@ -20,14 +20,14 @@ public class QueryApplicationConfiguration @Bean public QueryStreamProcessor usersStreamProcessor( 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(); @@ -40,11 +40,11 @@ public class QueryApplicationConfiguration 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); } -- 2.20.1