Enum Class GroupProtocol

java.lang.Object
java.lang.Enum<GroupProtocol>
org.apache.kafka.clients.consumer.GroupProtocol
All Implemented Interfaces:
Serializable, Comparable<GroupProtocol>, Constable

@Public public enum GroupProtocol extends Enum<GroupProtocol>
Enum representing the supported consumer group protocols.
  • CLASSIC - The Classic consumer group protocol (pre KIP-848)
  • CONSUMER - The Consumer rebalance protocol (KIP-848)
  • Enum Constant Details

    • CLASSIC

      public static final GroupProtocol CLASSIC
      Classic group protocol.
    • CONSUMER

      public static final GroupProtocol CONSUMER
      Consumer group protocol
  • Field Details

    • name

      public final String name
      String representation of the group protocol.
  • Method Details

    • values

      public static GroupProtocol[] values()
      Returns an array containing the constants of this enum class, in the order they are declared.
      Returns:
      an array containing the constants of this enum class, in the order they are declared
    • valueOf

      public static GroupProtocol valueOf(String name)
      Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)
      Parameters:
      name - the name of the enum constant to be returned.
      Returns:
      the enum constant with the specified name
      Throws:
      IllegalArgumentException - if this enum class has no constant with the specified name
      NullPointerException - if the argument is null
    • of

      public static GroupProtocol of(String name)
      Case-insensitive group protocol lookup by string name.
      Parameters:
      name - The name of the group protocol
      Returns:
      The corresponding GroupProtocol
      Throws:
      IllegalArgumentException - If the name does not match any protocol