org.apache.kafka.clients.admin

Class AlterBrokerHealthSpec

java.lang.Object

org.apache.kafka.clients.admin.AlterBrokerHealthSpec

public class AlterBrokerHealthSpec
extends Object

Constructor Summary

Constructors

Constructor and Description
AlterBrokerHealthSpec(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 Type	Method and Description
BrokerComponent	brokerComponent() Which broker component's health is being modified.
Set<Integer>	brokerIds() The list of brokers to alter broker health.
ComponentHealthStatus	componentHealthStatus() Whether to mark a broker component's health as degraded (0) or healthy (1).
boolean	equals(Object o)
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()
String	reason() An explanation for altering broker health.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

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 Detail

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