Package org.apache.kafka.common
Class Node
java.lang.Object
org.apache.kafka.common.Node
public class Node extends Object
Information about a Kafka node
-
Constructor Summary
-
Method Summary
Modifier and Type Method Description boolean
equals(Object obj)
int
hashCode()
boolean
hasRack()
True if this node has a defined rackString
host()
The host name for this nodeint
id()
The node id of this nodeString
idString()
String representation of the node id.boolean
isEmpty()
Check whether this node is empty, which may be the case if noNode() is used as a placeholder in a response payload with an error.static Node
noNode()
int
port()
The port for this nodeString
rack()
The rack for this nodeString
toString()
-
Constructor Details
-
Node
-
Node
-
-
Method Details
-
noNode
-
isEmpty
public boolean isEmpty()Check whether this node is empty, which may be the case if noNode() is used as a placeholder in a response payload with an error.- Returns:
- true if it is, false otherwise
-
id
public int id()The node id of this node -
idString
String representation of the node id. Typically the integer id is used to serialize over the wire, the string representation is used as an identifier with NetworkClient code -
host
The host name for this node -
port
public int port()The port for this node -
hasRack
public boolean hasRack()True if this node has a defined rack -
rack
The rack for this node -
hashCode
public int hashCode() -
equals
-
toString
-