本文整理了Java中org.apache.kafka.clients.admin.AdminClient.electPreferredLeaders()方法的一些代码示例，展示了AdminClient.electPreferredLeaders()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。AdminClient.electPreferredLeaders()方法的具体详情如下：
包路径：org.apache.kafka.clients.admin.AdminClient
类名称：AdminClient
方法名：electPreferredLeaders

AdminClient.electPreferredLeaders介绍

[英]Elect the preferred broker of the given partitions as leader, or elect the preferred broker for all partitions as leader if the argument to partitions is null. This is a convenience method for #electPreferredLeaders(Collection,ElectPreferredLeadersOptions)with default options. See the overload for more details.
[中]选择给定分区的首选代理作为leader，或者如果分区的参数为null，则选择所有分区的首选代理作为leader。对于带有默认选项的#electPreferredLeaders（集合，electPreferredLeaders选项），这是一种方便的方法。有关更多详细信息，请参阅重载。

代码示例

代码示例来源：origin: apache/kafka

/**
 * Elect the preferred broker of the given {@code partitions} as leader, or
 * elect the preferred broker for all partitions as leader if the argument to {@code partitions} is null.
 *
 * This is a convenience method for {@link #electPreferredLeaders(Collection, ElectPreferredLeadersOptions)}
 * with default options.
 * See the overload for more details.
 *
 * @param partitions      The partitions for which the preferred leader should be elected.
 * @return                The ElectPreferredLeadersResult.
 */
public ElectPreferredLeadersResult electPreferredLeaders(Collection<TopicPartition> partitions) {
  return electPreferredLeaders(partitions, new ElectPreferredLeadersOptions());
}

代码示例来源：origin: apache/kafka

responseData.replicaElectionResults().add(r);
env.kafkaClient().prepareResponse(new ElectPreferredLeadersResponse(responseData));
ElectPreferredLeadersResult results = env.adminClient().electPreferredLeaders(asList(topic1, topic2));
results.partitionResult(topic1).get();
TestUtils.assertFutureError(results.partitionResult(topic2), ClusterAuthorizationException.class);
env.kafkaClient().prepareResponse(new ElectPreferredLeadersResponse(responseData));
results = env.adminClient().electPreferredLeaders(asList(topic1, topic2));
results.partitionResult(topic1).get();
results.partitionResult(topic2).get();
results = env.adminClient().electPreferredLeaders(asList(topic1, topic2), new ElectPreferredLeadersOptions().timeoutMs(100));
TestUtils.assertFutureError(results.partitionResult(topic1), TimeoutException.class);
TestUtils.assertFutureError(results.partitionResult(topic2), TimeoutException.class);