@Bean
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();
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);
}