org.apache.kafka.streams.state

Class HostInfo

java.lang.Object

org.apache.kafka.streams.state.HostInfo

public class HostInfo
extends java.lang.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 org.apache.kafka.streams.processor.internals.StreamPartitionAssignor 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(java.lang.String host, int port)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HostInfo

public HostInfo(java.lang.String host,
        int port)

Method Detail

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

host

public java.lang.String host()

port

public int port()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object