public class HostInfo
extends java.lang.Object
KafkaStreams
application.
Instances of this class can be obtained by calling one of:
KafkaStreams.allMetadata()
KafkaStreams.allMetadataForStore(String)
KafkaStreams.metadataForKey(String, Object, StreamPartitioner)
KafkaStreams.metadataForKey(String, Object, Serializer)
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 and Description |
---|
HostInfo(java.lang.String host,
int port) |
Modifier and Type | Method and Description |
---|---|
static HostInfo |
buildFromEndpoint(java.lang.String endPoint) |
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.lang.String |
host() |
int |
port() |
java.lang.String |
toString() |
static HostInfo |
unavailable() |
public static HostInfo buildFromEndpoint(java.lang.String endPoint)
org.apache.kafka.common.config.ConfigException
- if the host or port cannot be parsed from the given endpoint stringpublic static HostInfo unavailable()
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String host()
public int port()
public java.lang.String toString()
toString
in class java.lang.Object