Package org.apache.kafka.clients.consumer.internals

Class AbstractCoordinator.Generation

java.lang.Object
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.Generation
Enclosing class:
AbstractCoordinator
protected static class AbstractCoordinator.Generation extends Object

  • Field Details

    • NO_GENERATION

      public static final AbstractCoordinator.Generation NO_GENERATION

    • generationId

      public final int generationId

    • memberId

      public final String memberId

    • protocolName

      public final String protocolName

  • Constructor Details

    • Generation

      public Generation(int generationId, String memberId, String protocolName)

  • Method Details

    • hasMemberId

      public boolean hasMemberId()
      Returns:
      true if this generation has a valid member id, false otherwise. A member might have an id before it becomes part of a group generation.

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object