class KafkaOperations implements AutoCloseable {

    public ConsumerGroupDetails getConsumerGroupDetails(final String consumerGroupId) {
        final List<ConsumerGroupDetails> consumerGroupDetails = getConsumerGroupDetails(
            Collections.singletonList(consumerGroupId)
        );

        // There should only be a single entry
        if (consumerGroupDetails.size() == 1) {
            return consumerGroupDetails.get(0);
        }
        // If we had zero or more than one.... not sure... toss exception
        throw new RuntimeException("Unable to locate consumer group id " + consumerGroupId);
    }

    public  KafkaOperations(final AdminClient adminClient, final KafkaConsumer<String, String> consumerClient);

}