Interface StreamsMetadata

Method Details

• 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()

  Source topic partitions for which the instance acts as standby.

  Returns:

  source 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.