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

AdminClient.describeConsumerGroups介绍

[英]Describe some group IDs in the cluster, with the default options.

This is a convenience method for # AdminClient#describeConsumerGroups(Collection,DescribeConsumerGroupsOptions) with default options. See the overload for more details.
[中]使用默认选项描述集群中的一些组ID。
对于带有默认选项的#AdminClient#describeConsumerGroups（集合、describeConsumerGroups选项），这是一种方便的方法。有关更多详细信息，请参阅重载。

代码示例

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

/**
 * Describe some group IDs in the cluster, with the default options.
 * <p>
 * This is a convenience method for
 * #{@link AdminClient#describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)} with
 * default options. See the overload for more details.
 *
 * @param groupIds The IDs of the groups to describe.
 * @return The DescribeConsumerGroupResult.
 */
public DescribeConsumerGroupsResult describeConsumerGroups(Collection<String> groupIds) {
  return describeConsumerGroups(groupIds, new DescribeConsumerGroupsOptions());
}

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

final DescribeConsumerGroupsResult result = env.adminClient().describeConsumerGroups(singletonList("group-0"));
final ConsumerGroupDescription groupDescription = result.describedGroups().get("group-0").get();

代码示例来源：origin: org.apache.kafka/kafka_2.12

private void validateNoActiveConsumers(final String groupId,
                    final AdminClient adminClient) throws ExecutionException, InterruptedException {
  final DescribeConsumerGroupsResult describeResult = adminClient.describeConsumerGroups(Arrays.asList(groupId),
      (new DescribeConsumerGroupsOptions()).timeoutMs(10 * 1000));
  final List<MemberDescription> members =
    new ArrayList<MemberDescription>(describeResult.describedGroups().get(groupId).get().members());
  if (!members.isEmpty()) {
    throw new IllegalStateException("Consumer group '" + groupId + "' is still active "
        + "and has following members: " + members + ". "
        + "Make sure to stop all running application instances before running the reset tool.");
  }
}

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

private void validateNoActiveConsumers(final String groupId,
                    final AdminClient adminClient) throws ExecutionException, InterruptedException {
  final DescribeConsumerGroupsResult describeResult = adminClient.describeConsumerGroups(Arrays.asList(groupId),
      (new DescribeConsumerGroupsOptions()).timeoutMs(10 * 1000));
  final List<MemberDescription> members =
    new ArrayList<MemberDescription>(describeResult.describedGroups().get(groupId).get().members());
  if (!members.isEmpty()) {
    throw new IllegalStateException("Consumer group '" + groupId + "' is still active "
        + "and has following members: " + members + ". "
        + "Make sure to stop all running application instances before running the reset tool.");
  }
}

代码示例来源：origin: org.apache.kafka/kafka_2.11

private void validateNoActiveConsumers(final String groupId,
                    final AdminClient adminClient) throws ExecutionException, InterruptedException {
  final DescribeConsumerGroupsResult describeResult = adminClient.describeConsumerGroups(Arrays.asList(groupId),
      (new DescribeConsumerGroupsOptions()).timeoutMs(10 * 1000));
  final List<MemberDescription> members =
    new ArrayList<MemberDescription>(describeResult.describedGroups().get(groupId).get().members());
  if (!members.isEmpty()) {
    throw new IllegalStateException("Consumer group '" + groupId + "' is still active "
        + "and has following members: " + members + ". "
        + "Make sure to stop all running application instances before running the reset tool.");
  }
}

代码示例来源：origin: allegro/hermes

private int numberOfAssignmentsForConsumersGroups(List<String> consumerGroupsIds) throws ExecutionException, InterruptedException {
  Collection<ConsumerGroupDescription> consumerGroupsDescriptions = adminClient.describeConsumerGroups(consumerGroupsIds).all().get().values();
  Stream<MemberDescription> memberDescriptions = consumerGroupsDescriptions.stream().flatMap(desc -> desc.members().stream());
  return memberDescriptions.flatMap(memberDescription -> memberDescription.assignment().topicPartitions().stream()).collect(Collectors.toList()).size();
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.kafka_2.11

private void validateNoActiveConsumers(final String groupId,
                    final AdminClient adminClient) throws ExecutionException, InterruptedException {
  final DescribeConsumerGroupsResult describeResult = adminClient.describeConsumerGroups(Arrays.asList(groupId),
      (new DescribeConsumerGroupsOptions()).timeoutMs(10 * 1000));
  final List<MemberDescription> members =
    new ArrayList<MemberDescription>(describeResult.describedGroups().get(groupId).get().members());
  if (!members.isEmpty()) {
    throw new IllegalStateException("Consumer group '" + groupId + "' is still active "
        + "and has following members: " + members + ". "
        + "Make sure to stop all running application instances before running the reset tool.");
  }
}

代码示例来源：origin: SourceLabOrg/kafka-webview

final DescribeConsumerGroupsResult results = adminClient.describeConsumerGroups(consumerGroupIds);