package io.vertx.groovy.kafka.admin;
public class KafkaAdminClient_GroovyExtension {
  public static void createTopics(io.vertx.kafka.admin.KafkaAdminClient j_receiver, java.util.List<java.util.Map<String, Object>> topics, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    j_receiver.createTopics(topics != null ? topics.stream().map(elt -> elt != null ? new io.vertx.kafka.admin.NewTopic(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toList()) : null,
      completionHandler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>() {
      public void handle(io.vertx.core.AsyncResult<java.lang.Void> ar) {
        completionHandler.handle(ar.map(event -> io.vertx.core.impl.ConversionHelper.fromObject(event)));
      }
    } : null);
  }
  public static void listConsumerGroups(io.vertx.kafka.admin.KafkaAdminClient j_receiver, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<java.util.Map<String, Object>>>> completionHandler) {
    j_receiver.listConsumerGroups(completionHandler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.admin.ConsumerGroupListing>>>() {
      public void handle(io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.admin.ConsumerGroupListing>> ar) {
        completionHandler.handle(ar.map(event -> event != null ? event.stream().map(elt -> elt != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(elt.toJson()) : null).collect(java.util.stream.Collectors.toList()) : null));
      }
    } : null);
  }
}