io.vertx/vertx-lang-groovy/3.8.0 : io/vertx/groovy/kafka/client/consumer/KafkaConsumer

KafkaConsumer_GroovyExtension
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-lang-groovy-parent/vertx-lang-groovy: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
package io.vertx.groovy.kafka.client.consumer;
public class KafkaConsumer_GroovyExtension {
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> assign(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.assign(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> assign(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.assign(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> assign(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.assign(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> assign(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.assign(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> assignment(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<java.util.Map<String, Object>>>> handler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.assignment(handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<io.vertx.kafka.client.common.TopicPartition>>>() {
      public void handle(io.vertx.core.AsyncResult<java.util.Set<io.vertx.kafka.client.common.TopicPartition>> ar) {
        handler.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.toSet()) : null));
      }
    } : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> pause(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.pause(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> pause(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.pause(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> pause(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.pause(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> pause(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.pause(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : 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));
    return j_receiver;
  }
  public static void paused(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<java.util.Map<String, Object>>>> handler) {
    j_receiver.paused(handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<io.vertx.kafka.client.common.TopicPartition>>>() {
      public void handle(io.vertx.core.AsyncResult<java.util.Set<io.vertx.kafka.client.common.TopicPartition>> ar) {
        handler.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.toSet()) : null));
      }
    } : null);
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> resume(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.resume(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> resume(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.resume(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> resume(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.resume(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> resume(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.resume(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> partitionsRevokedHandler(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, io.vertx.core.Handler<java.util.Set<java.util.Map<String, Object>>> handler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.partitionsRevokedHandler(handler != null ? event -> handler.handle(event != null ? event.stream().map(elt -> elt != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(elt.toJson()) : null).collect(java.util.stream.Collectors.toSet()) : null) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> partitionsAssignedHandler(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, io.vertx.core.Handler<java.util.Set<java.util.Map<String, Object>>> handler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.partitionsAssignedHandler(handler != null ? event -> handler.handle(event != null ? event.stream().map(elt -> elt != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(elt.toJson()) : null).collect(java.util.stream.Collectors.toSet()) : null) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seek(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, long offset) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seek(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null,
      offset));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seek(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, long offset, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seek(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null,
      offset,
      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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToBeginning(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToBeginning(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToBeginning(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToBeginning(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToBeginning(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToBeginning(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToBeginning(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToBeginning(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToEnd(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToEnd(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToEnd(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToEnd(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : null));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToEnd(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToEnd(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : 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));
    return j_receiver;
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> seekToEnd(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Set<java.util.Map<String, Object>> topicPartitions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>> completionHandler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.seekToEnd(topicPartitions != null ? topicPartitions.stream().map(elt -> elt != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(elt)) : null).collect(java.util.stream.Collectors.toSet()) : 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));
    return j_receiver;
  }
  public static void committed(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<String, Object>>> handler) {
    j_receiver.committed(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null,
      handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.OffsetAndMetadata>>() {
      public void handle(io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.OffsetAndMetadata> ar) {
        handler.handle(ar.map(event -> event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null));
      }
    } : null);
  }
  public static io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.Object,java.lang.Object> partitionsFor(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.lang.String topic, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<java.util.Map<String, Object>>>> handler) {
    io.vertx.core.impl.ConversionHelper.fromObject(j_receiver.partitionsFor(topic,
      handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.client.common.PartitionInfo>>>() {
      public void handle(io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.client.common.PartitionInfo>> ar) {
        handler.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));
    return j_receiver;
  }
  public static void position(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> partition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> handler) {
    j_receiver.position(partition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(partition)) : null,
      handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>() {
      public void handle(io.vertx.core.AsyncResult<java.lang.Long> ar) {
        handler.handle(ar.map(event -> event));
      }
    } : null);
  }
  public static void offsetsForTimes(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, java.lang.Long timestamp, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<String, Object>>> handler) {
    j_receiver.offsetsForTimes(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null,
      timestamp,
      handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.OffsetAndTimestamp>>() {
      public void handle(io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.OffsetAndTimestamp> ar) {
        handler.handle(ar.map(event -> event != null ? io.vertx.core.impl.ConversionHelper.fromJsonObject(event.toJson()) : null));
      }
    } : null);
  }
  public static void beginningOffsets(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> handler) {
    j_receiver.beginningOffsets(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null,
      handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>() {
      public void handle(io.vertx.core.AsyncResult<java.lang.Long> ar) {
        handler.handle(ar.map(event -> event));
      }
    } : null);
  }
  public static void endOffsets(io.vertx.kafka.client.consumer.KafkaConsumer<Object, Object> j_receiver, java.util.Map<String, Object> topicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>> handler) {
    j_receiver.endOffsets(topicPartition != null ? new io.vertx.kafka.client.common.TopicPartition(io.vertx.core.impl.ConversionHelper.toJsonObject(topicPartition)) : null,
      handler != null ? new io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>() {
      public void handle(io.vertx.core.AsyncResult<java.lang.Long> ar) {
        handler.handle(ar.map(event -> event));
      }
    } : null);
  }
}
/

io.vertx/ vertx-lang-groovy/ 3.8.0/ io/vertx/groovy/kafka/client/consumer/KafkaConsumer_GroovyExtension.java
