Package org.apache.kafka.clients.admin
Class AlterBrokerHealthSpec
java.lang.Object
org.apache.kafka.clients.admin.AlterBrokerHealthSpec
-
Constructor Summary
ConstructorsConstructorDescriptionAlterBrokerHealthSpec
(Set<Integer> brokerIds, BrokerComponent brokerComponent, ComponentHealthStatus componentHealthStatus, String reason) AlterBrokerHealthSpec
(Set<Integer> brokerIds, BrokerComponent brokerComponent, ComponentHealthStatus componentHealthStatus, String reason, boolean force) AlterBrokerHealthSpec
(Set<Integer> brokerIds, ComponentHealthStatus componentHealthStatus, String reason) -
Method Summary
Modifier and TypeMethodDescriptionWhich broker component's health is being modified.The list of brokers to alter broker health.Whether to mark a broker component's health as degraded (0) or healthy (1).boolean
boolean
force()
Whether the operation will be forced if the cluster has already reached the max number of brokers that can be demoted.int
hashCode()
reason()
An explanation for altering broker health.toString()
-
Constructor Details
-
AlterBrokerHealthSpec
public AlterBrokerHealthSpec(Set<Integer> brokerIds, ComponentHealthStatus componentHealthStatus, String reason) -
AlterBrokerHealthSpec
public AlterBrokerHealthSpec(Set<Integer> brokerIds, BrokerComponent brokerComponent, ComponentHealthStatus componentHealthStatus, String reason) -
AlterBrokerHealthSpec
public AlterBrokerHealthSpec(Set<Integer> brokerIds, BrokerComponent brokerComponent, ComponentHealthStatus componentHealthStatus, String reason, boolean force)
-
-
Method Details
-
reason
An explanation for altering broker health. -
brokerIds
The list of brokers to alter broker health. -
brokerComponent
Which broker component's health is being modified. One of unspecified (0), storage (1), or network (2). -
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
-
equals
-
hashCode
public int hashCode()
-