public interface StreamsMetadata
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object o)
Compares the specified object with this StreamsMetadata.
|
int |
hashCode()
Returns the hash code value for this TaskMetadata.
|
String |
host()
Host where the Streams client runs.
|
HostInfo |
hostInfo()
The value of
StreamsConfig.APPLICATION_SERVER_CONFIG configured for the Streams
client. |
int |
port()
Port on which the Streams client listens.
|
Set<String> |
standbyStateStoreNames()
Names of the state stores assigned to standby tasks of the Streams client.
|
Set<TopicPartition> |
standbyTopicPartitions()
Changelog topic partitions for the state stores the standby tasks of the Streams client replicates.
|
Set<String> |
stateStoreNames()
Names of the state stores assigned to active tasks of the Streams client.
|
Set<TopicPartition> |
topicPartitions()
Source topic partitions of the active tasks of the Streams client.
|
HostInfo hostInfo()
StreamsConfig.APPLICATION_SERVER_CONFIG configured for the Streams
client.HostInfo corresponding to the Streams clientSet<String> stateStoreNames()
Set<TopicPartition> topicPartitions()
Set<TopicPartition> standbyTopicPartitions()
Set<String> standbyStateStoreNames()
String host()
This method is equivalent to StreamsMetadata.hostInfo().host();
int port()
This method is equivalent to StreamsMetadata.hostInfo().port();
boolean equals(Object o)
true if and only if the specified object is
also a StreamsMetadata and for both hostInfo() are equal, and stateStoreNames(), topicPartitions(),
standbyStateStoreNames(), and standbyTopicPartitions() contain the same elements.int hashCode()
Objects.hash(hostInfo(), stateStoreNames(), topicPartitions(), standbyStateStoreNames(), standbyTopicPartitions());