@InterfaceStability.Evolving public final class ElectLeadersResult extends java.lang.Object
Admin.electLeaders(ElectionType, Set, ElectLeadersOptions)
The API of this class is evolving, see Admin
for details.Modifier and Type | Method and Description |
---|---|
KafkaFuture<java.lang.Void> |
all()
Return a future which succeeds if all the topic elections succeed.
|
KafkaFuture<java.util.Map<TopicPartition,java.util.Optional<java.lang.Throwable>>> |
partitions()
Get a future for the topic partitions for which a leader election was attempted.
|
public KafkaFuture<java.util.Map<TopicPartition,java.util.Optional<java.lang.Throwable>>> partitions()
Get a future for the topic partitions for which a leader election was attempted. If the election succeeded then the value for a topic partition will be the empty Optional. Otherwise the election failed and the Optional will be set with the error.
public KafkaFuture<java.lang.Void> all()