streams = new KafkaStreams(topology, props);
hostInfo = applicationServer;
storeParameters = StoreQueryParameters.fromNameAndType(STORE_NAME, QueryableStoreTypes.keyValueStore());;
streams = new KafkaStreams(topology, props);
hostInfo = applicationServer;
storeParameters = StoreQueryParameters.fromNameAndType(STORE_NAME, QueryableStoreTypes.keyValueStore());;