public class StreamsMetadataState
extends java.lang.Object
StreamsMetadata
in a KafkaStreams application. This can be used
to discover the locations of StateStore
s
in a KafkaStreams applicationModifier and Type | Field and Description |
---|---|
static HostInfo |
UNKNOWN_HOST |
Constructor and Description |
---|
StreamsMetadataState(InternalTopologyBuilder builder,
HostInfo thisHost) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<StreamsMetadata> |
getAllMetadata()
Find all of the
StreamsMetadata s in a
application |
java.util.Collection<StreamsMetadata> |
getAllMetadataForStore(java.lang.String storeName)
Find all of the
StreamsMetadata s for a given storeName |
<K> StreamsMetadata |
getMetadataWithKey(java.lang.String storeName,
K key,
org.apache.kafka.common.serialization.Serializer<K> keySerializer)
Find the
StreamsMetadata s for a given storeName and key. |
<K> StreamsMetadata |
getMetadataWithKey(java.lang.String storeName,
K key,
StreamPartitioner<? super K,?> partitioner)
Find the
StreamsMetadata s for a given storeName and key. |
java.lang.String |
toString() |
java.lang.String |
toString(java.lang.String indent) |
public static final HostInfo UNKNOWN_HOST
public StreamsMetadataState(InternalTopologyBuilder builder, HostInfo thisHost)
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String toString(java.lang.String indent)
public java.util.Collection<StreamsMetadata> getAllMetadata()
StreamsMetadata
s in a
application
StreamsMetadata
s in a KafkaStreams
applicationpublic java.util.Collection<StreamsMetadata> getAllMetadataForStore(java.lang.String storeName)
StreamsMetadata
s for a given storeNamestoreName
- the storeName to find metadata forStreamsMetadata
that have the provided storeNamepublic <K> StreamsMetadata getMetadataWithKey(java.lang.String storeName, K key, org.apache.kafka.common.serialization.Serializer<K> keySerializer)
StreamsMetadata
s for a given storeName and key. This method will use the
DefaultStreamPartitioner
to locate the store. If a custom partitioner has been used
please use getMetadataWithKey(String, Object, StreamPartitioner)
Note: the key may not exist in the StateStore
,
this method provides a way of finding which StreamsMetadata
it would exist on.K
- key typestoreName
- Name of the storekey
- Key to usekeySerializer
- Serializer for the keyStreamsMetadata
for the storeName and key or StreamsMetadata.NOT_AVAILABLE
if streams is (re-)initializingpublic <K> StreamsMetadata getMetadataWithKey(java.lang.String storeName, K key, StreamPartitioner<? super K,?> partitioner)
StreamsMetadata
s for a given storeName and key.
Note: the key may not exist in the StateStore
,
this method provides a way of finding which StreamsMetadata
it would exist on.K
- key typestoreName
- Name of the storekey
- Key to usepartitioner
- partitioner to use to find correct partition for keyStreamsMetadata
for the storeName and key or StreamsMetadata.NOT_AVAILABLE
if streams is (re-)initializing