Class AlterBrokerHealthSpec

java.lang.Object
org.apache.kafka.clients.admin.AlterBrokerHealthSpec

public class AlterBrokerHealthSpec extends Object
  • Constructor Details

  • Method Details

    • reason

      public String reason()
      An explanation for altering broker health.
    • brokerIds

      public Set<Integer> brokerIds()
      The list of brokers to alter broker health.
    • brokerComponent

      public BrokerComponent brokerComponent()
      Which broker component's health is being modified. One of unspecified (0), storage (1), or network (2).
    • componentHealthStatus

      public ComponentHealthStatus componentHealthStatus()
      Whether to mark a broker component's health as degraded (0) or healthy (1).
    • force

      public boolean force()
      Whether the operation will be forced if the cluster has already reached the max number of brokers that can be demoted. This is ignored for v0 requests, and all demotions will be allowed.
    • toString

      public String toString()
      Overrides:
      toString in class Object
    • equals

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

      public int hashCode()
      Overrides:
      hashCode in class Object