public class HostInfo extends Object
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.| Modifier and Type | Method and Description |
|---|---|
static HostInfo | buildFromEndpoint(String endPoint) |
boolean | equals(Object o) |
int | hashCode() |
String | host() |
int | port() |
String | toString() |
static HostInfo | unavailable() |
public HostInfo(String host, int port)
public static HostInfo buildFromEndpoint(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 String host()
public int port()