public int getCurrentConsumerCount()

in src/main/java/com/google/cloud/run/kafkascaler/Kafka.java [68:74]

• 6 lines of code
• 2 McCabe index (conditional complexity)

  public int getCurrentConsumerCount(String consumerGroupId)
      throws InterruptedException, ExecutionException {
    ConsumerGroupDescription consumerGroupDescription =
        adminClient.describeConsumerGroup(consumerGroupId);

    return consumerGroupDescription == null ? 0 : consumerGroupDescription.members().size();
  }