org.apache.kafka.streams.state

Class HostInfo

java.lang.Object

org.apache.kafka.streams.state.HostInfo

public class HostInfo
extends Object

Represents a user defined endpoint in a 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 Summary

Constructors

Constructor and Description
HostInfo(String host, int port)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	hashCode()
String	host()
int	port()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HostInfo

public HostInfo(String host,
                int port)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

host

public String host()

port

public int port()

toString

public String toString()

Overrides:

toString in class Object