org.apache.kafka.clients.admin

Class DegradedBroker

java.lang.Object

org.apache.kafka.clients.admin.DegradedBroker

public class DegradedBroker
extends Object

Constructor Summary

Constructors

Constructor and Description
DegradedBroker(int brokerId, Set<DegradedBrokerComponent> degradedBrokerComponents)

Method Summary

Modifier and Type	Method and Description
int	brokerId() The brokerId whose health state we want to alter.
Set<DegradedBrokerComponent>	degradedBrokerComponents() The set of degraded broker components.
boolean	equals(Object o)
int	hashCode()
List<String>	reasons() The list of reasons that this broker is currently degraded for.
org.apache.kafka.common.message.DescribeBrokerHealthResponseData.DegradedBroker	response(short requestVersion) Generates the response object using the request version.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

DegradedBroker

public DegradedBroker(int brokerId,
                      Set<DegradedBrokerComponent> degradedBrokerComponents)

Method Detail

brokerId

public int brokerId()

The brokerId whose health state we want to alter.

degradedBrokerComponents

public Set<DegradedBrokerComponent> degradedBrokerComponents()

The set of degraded broker components.

reasons

public List<String> reasons()

The list of reasons that this broker is currently degraded for.

response

public org.apache.kafka.common.message.DescribeBrokerHealthResponseData.DegradedBroker response(short requestVersion)

Generates the response object using the request version.

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