Class Node


  • public class Node
    extends Object
    Information about a Kafka node
    • 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