Package org.apache.kafka.streams.state
Class HostInfo
java.lang.Object
org.apache.kafka.streams.state.HostInfo
Represents a user defined endpoint in a
KafkaStreams
application.
Instances of this class can be obtained by calling one of:
KafkaStreams.metadataForAllStreamsClients()
KafkaStreams.streamsMetadataForStore(String)
The HostInfo is constructed during Partition Assignment
see StreamsPartitionAssignor
It is extracted from the config StreamsConfig.APPLICATION_SERVER_CONFIG
If developers wish to expose an endpoint in their KafkaStreams applications they should provide the above
config.-
Constructor Summary
-
Method Summary
-
Constructor Details
-
HostInfo
-
-
Method Details
-
buildFromEndpoint
- Returns:
- a new HostInfo or null if endPoint is null or has no characters
- Throws:
ConfigException
- if the host or port cannot be parsed from the given endpoint string
-
equals
-
hashCode
public int hashCode() -
host
-
port
public int port() -
toString
-