我有一个kafka流应用程序运行36个不同的示例（每个分区一个）。我正在州上建立rest服务来访问数据。
下面是一些访问数据的代码

StreamsMetadata metadata = streams.metadataForKey(store, key, serializer); --> call this find ouy which host has the key
if (localSelf.host().equals(hostStoreInfo.getHost())) {
get the key from local store
}
else {
call the remote host using restTemplate

现在的问题是 metadata 返回的对象具有不同的主机/ip，但数据位于不同的节点上。我可以看到使用我打印的一些应用程序日志。
这个 allMetadata 上的方法 KafkaStreams 表示该值将在重新分配分区时更新。但这种情况不会发生。我能做什么。