public <K> KeyQueryMetadata queryMetadataForKey(final String storeName,
                                                    final K key,
                                                    final Serializer<K> keySerializer,
                                                    final String topologyName) {
        verifyTopologyStateStore(topologyName, storeName);
        validateIsRunningOrRebalancing();
        return streamsMetadataState.getKeyQueryMetadataForKey(storeName, key, keySerializer, topologyName);
    }
See {@link KafkaStreams#queryMetadataForKey(String, Object, Serializer)}
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java