THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block |
|---|
/**
* Elect the preferred replica of the given {@code partitions} as leader, or
* elect the preferred replica for all partitions as leader if the argument to {@code partitions} is null.
*
* This operation is supported by brokers with version 1.0 or higher.
*/
ElectPreferredLeadersResult electPreferredLeaders(Collection<TopicPartition> partitions, ElectPreferredLeadersOptions options)
ElectPreferredLeadersResult electPreferredLeadersCollection<TopicPartition>electPreferredLeaders(Collection<TopicPartition> partitions) |
Where
| Code Block |
|---|
class ElectPreferredLeadersOptions {
public ElectPreferredLeadersOptions() { ... }
/**
* The request timeout in milliseconds for this operation or {@code null} if the default request timeout for the
* AdminClient should be used.
*/
public Integer timeoutMs() { ... }
/**
* Set the request timeout in milliseconds for this operation or {@code null} if the default request timeout for the
* AdminClient should be used.
*/
public ElectPreferredLeadersOptions timeoutMs(Integer timeoutMs) { ... }
}
class ElectPreferredLeadersResult {
// package access constructor
Map<TopicPartition, KafkaFuture<Void>> values() { ... }
KafkaFuture<Void> all() { ... }
} |
...