anchor.diff:  However, when you use the low-level Processor API in your application, there are options to control this behavior. See 
   below.
   
  -
   [source]
   ----
   @Autowired
  
positive.code: }
  ----
  
  Access code:
  [source]
  ----
  Processor<Object, Product>() {
  
negative.code: [source]
  ----
  ReadOnlyKeyValueStore<Object, Object> keyValueStore =
  						interactiveQueryService.getQueryableStoreType("my-store", QueryableStoreTypes.keyValueStore());
  ----
  
  If there are multiple instances of the kafka streams application running, then before you can query them interactively, you need to identify which application instance hosts the key.
  `InteractiveQueryService` API provides methods for identifying the host information.
  
  In order for this to work, you must configure the property `application.server` as below:
  
  [source]
  ----
  spring.cloud.stream.kafka.streams.binder.configuration.application.server: <server>:<port>
  ----
  
  Here are some code snippets:
  
  [source]
  ----
  org.apache.kafka.streams.state.HostInfo hostInfo = interactiveQueryService.getHostInfo("store-name",
  						key, keySerializer);
  
  if (interactiveQueryService.getCurrentHostInfo().equals(hostInfo)) {
  
      //query from the store that is locally available
  }
  else {
      //query from the remote host
  }
  ----
  