org.apache.kafka.common

Class Node

java.lang.Object

org.apache.kafka.common.Node

Direct Known Subclasses:

ConfluentNode

public class Node
extends Object

Information about a Kafka node

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	hash
protected String	host
protected int	id
protected String	idString
protected int	port
protected String	rack

Constructor Summary

Constructors

Constructor and Description
Node(int id, String host, int port)
Node(int id, String host, int port, String rack)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
boolean	hasRack() True if this node has a defined rack
String	host() The host name for this node
int	id() The node id of this node
String	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 node
String	rack() The rack for this node
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

id

protected final int id

idString

protected final String idString

host

protected final String host

port

protected final int port

rack

protected final String rack

hash

protected Integer hash

Constructor Detail

Node

public Node(int id,
            String host,
            int port)

Node

public Node(int id,
            String host,
            int port,
            String rack)

Method Detail

noNode

public static Node 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

public String 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

public String 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

public String rack()

The rack for this node

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object