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 |
---|---|
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.lang.String |
host() |
int |
port() |
java.lang.String |
toString() |
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