THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
package org.apache.kafka.streams; public class KafkaStreams { ... // Actual javadoc will be comprehensive, notes below are for illustration for the KIP /** * Returns {@link KeyQueryMetadataStreamsMetadata} for each {@code KafkaStreams} instance of this application, * that hosts standby state stores */ public Collection<StreamsMetadata> allStandbyMetadata() {} /** * Returns {@link KeyQueryMetadataStreamsMetadata} for each {@code KafkaStreams} instance of this application, * that hosts standby state stores for the given store. */ public Collection<KeyQueryMetadata>Collection<StreamsMetadata> allStandbyMetadataForStore(final String storeName) {} /** * Returns {@link KeyQueryMetadata} for all instances that hosts the given key as a standby * for the given store. */ public <K> Collection<KeyQueryMetadata>KeyQueryMetadata standbyMetadataForKey(final String storeName, final K key, final Serializer<K> keySerializer) {} /** * Returns {@link KeyQueryMetadata} for all instances that hosts the given key as a standby, * determined by the given partitioner, for the given store. */ public <K> Collection<KeyQueryMetadata>KeyQueryMetadata standbyMetadataForKey(final String storeName, final K key, final StreamPartitioner<? super K, ?> partitioner) {} ... } |
...