Package org.apache.kafka.common

Class Node

  • public class Node
extends java.lang.Object
    Information about a Kafka node

    • Constructor Summary

      Constructors 
      Constructor Description
      Node​(int id, java.lang.String host, int port)  
      Node​(int id, java.lang.String host, int port, java.lang.String rack)  

    • Method Summary

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

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • Node

        public Node​(int id,
            java.lang.String host,
            int port)

      • Node

        public Node​(int id,
            java.lang.String host,
            int port,
            java.lang.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 java.lang.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 java.lang.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 java.lang.String rack()
        The rack for this node

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object

      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object