public interface AliveBrokersMetadata
Modifier and Type | Method and Description |
---|---|
Set<Integer> |
aliveBrokers()
Returns the brokers that are alive in the cluster
|
Set<Integer> |
demotedBrokers()
Returns the demoted brokers in the cluster.
|
Optional<org.apache.kafka.common.Endpoint> |
endpointFor(org.apache.kafka.common.network.ListenerName listenerName)
Fetch an endpoint with a particular listener name from any broker in the cluster.
|
Optional<Long> |
epochFor(int brokerId)
Returns the broker epoch for the broker with ID
brokerId . |
boolean |
isEmpty() |
Set<Integer> |
replicaExclusions()
Returns the active broker replica placement exclusions in the cluster
|
Set<Integer> replicaExclusions()
Optional<Long> epochFor(int brokerId)
brokerId
. Empty if no such broker or epoch exists.Optional<org.apache.kafka.common.Endpoint> endpointFor(org.apache.kafka.common.network.ListenerName listenerName)
listenerName
- the name of the listener for which an endpoint should be returnedlistenerName
, on any broker in the metadataboolean isEmpty()