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).booleanbooleanforce()Whether the operation will be forced if the cluster has already reached the max number of brokers that can be demoted.inthashCode()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
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