public class StreamsMetadata extends Object
KafkaStreams
application.
It contains the user supplied HostInfo
that can be used by developers to build
APIs and services to connect to other instances, the Set of state stores available on
the instance and the Set of TopicPartition
s available on the instance.
NOTE: This is a point in time view. It may change when rebalances happen.Modifier and Type | Field and Description |
---|---|
static StreamsMetadata |
NOT_AVAILABLE
Sentinel to indicate that the StreamsMetadata is currently unavailable.
|
Constructor and Description |
---|
StreamsMetadata(HostInfo hostInfo,
Set<String> stateStoreNames,
Set<TopicPartition> topicPartitions) |
public static final StreamsMetadata NOT_AVAILABLE
public StreamsMetadata(HostInfo hostInfo, Set<String> stateStoreNames, Set<TopicPartition> topicPartitions)
public HostInfo hostInfo()
public Set<TopicPartition> topicPartitions()
public String host()
public int port()