org.apache.kafka.streams

Interface StreamsMetadata

public interface StreamsMetadata

Metadata of a Kafka Streams client.

Method Summary

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<org.apache.kafka.common.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<org.apache.kafka.common.TopicPartition>	topicPartitions() Source topic partitions of the active tasks of the Streams client.

Method Detail

hostInfo

HostInfo hostInfo()

The value of StreamsConfig.APPLICATION_SERVER_CONFIG configured for the Streams client.

Returns:

HostInfo corresponding to the Streams client

stateStoreNames

Set<String> stateStoreNames()

Names of the state stores assigned to active tasks of the Streams client.

Returns:

names of the state stores assigned to active tasks

topicPartitions

Set<org.apache.kafka.common.TopicPartition> topicPartitions()

Source topic partitions of the active tasks of the Streams client.

Returns:

source topic partitions of the active tasks

standbyTopicPartitions

Set<org.apache.kafka.common.TopicPartition> standbyTopicPartitions()

Changelog topic partitions for the state stores the standby tasks of the Streams client replicates.

Returns:

set of changelog topic partitions of the standby tasks

standbyStateStoreNames

Set<String> standbyStateStoreNames()

Names of the state stores assigned to standby tasks of the Streams client.

Returns:

names of the state stores assigned to standby tasks

host

String host()

Host where the Streams client runs. This method is equivalent to StreamsMetadata.hostInfo().host();

Returns:

the host where the Streams client runs

port

int port()

Port on which the Streams client listens. This method is equivalent to StreamsMetadata.hostInfo().port();

Returns:

the port on which Streams client listens

equals

boolean equals(Object o)

Compares the specified object with this StreamsMetadata. Returns 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.

Overrides:

equals in class Object

Returns:

true if this object is the same as the obj argument; false otherwise.

hashCode

int hashCode()

Returns the hash code value for this TaskMetadata. The hash code of a list is defined to be the result of the following calculation:

 
 Objects.hash(hostInfo(), stateStoreNames(), topicPartitions(), standbyStateStoreNames(), standbyTopicPartitions());
 
 

Overrides:

hashCode in class Object

Returns:

a hash code value for this object.