io.vertx/vertx-kafka-client/4.0.0 : io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.class

KafkaReadStreamImpl
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-kafka-client: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse)
public class io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> implements io.vertx.kafka.client.consumer.KafkaReadStream<K, V>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl
  super_class: java.lang.Object
{
  private static final java.util.concurrent.atomic.AtomicInteger threadCount;
    descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final io.vertx.core.Context context;
    descriptor: Lio/vertx/core/Context;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicBoolean closed;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.apache.kafka.clients.consumer.Consumer<K, V> consumer;
    descriptor: Lorg/apache/kafka/clients/consumer/Consumer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;

  private final io.vertx.kafka.client.common.tracing.ConsumerTracer tracer;
    descriptor: Lio/vertx/kafka/client/common/tracing/ConsumerTracer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicBoolean consuming;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLong demand;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicBoolean polling;
    descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> recordHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;

  private io.vertx.core.Handler<java.lang.Throwable> exceptionHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;

  private java.util.Iterator<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> current;
    descriptor: Ljava/util/Iterator;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/Iterator<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;

  private io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K, V>> batchHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;

  private io.vertx.core.Handler<java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsRevokedHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;

  private io.vertx.core.Handler<java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsAssignedHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;

  private java.time.Duration pollTimeout;
    descriptor: Ljava/time/Duration;
    flags: (0x0002) ACC_PRIVATE

  private java.util.concurrent.ExecutorService worker;
    descriptor: Ljava/util/concurrent/ExecutorService;
    flags: (0x0002) ACC_PRIVATE

  private final org.apache.kafka.clients.consumer.ConsumerRebalanceListener rebalanceListener;
    descriptor: Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 61
            new java.util.concurrent.atomic.AtomicInteger
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:(I)V
            putstatic io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.threadCount:Ljava/util/concurrent/atomic/AtomicInteger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(io.vertx.core.Vertx, org.apache.kafka.clients.consumer.Consumer<K, V>, io.vertx.kafka.client.common.KafkaClientOptions);
    descriptor: (Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.kafka.client.common.KafkaClientOptions options
         0: .line 106
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 64
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_1
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
         2: .line 68
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consuming:Ljava/util/concurrent/atomic/AtomicBoolean;
         3: .line 69
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            ldc 9223372036854775807
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:(J)V
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
         4: .line 70
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicBoolean
            dup
            iconst_0
            invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.polling:Ljava/util/concurrent/atomic/AtomicBoolean;
         5: .line 77
            aload 0 /* this */
            lconst_1
            invokestatic java.time.Duration.ofSeconds:(J)Ljava/time/Duration;
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pollTimeout:Ljava/time/Duration;
         6: .line 81
            aload 0 /* this */
            new io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl$1
            dup
            aload 0 /* this */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl$1.<init>:(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;)V
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.rebalanceListener:Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;
         7: .line 107
            aload 0 /* this */
            aload 2 /* consumer */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
         8: .line 108
            aload 1 /* vertx */
            invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
            checkcast io.vertx.core.impl.ContextInternal
            astore 4 /* ctxInt */
        start local 4 // io.vertx.core.impl.ContextInternal ctxInt
         9: .line 109
            aload 0 /* this */
            aload 4 /* ctxInt */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
        10: .line 110
            aload 0 /* this */
            aload 4 /* ctxInt */
            invokeinterface io.vertx.core.impl.ContextInternal.tracer:()Lio/vertx/core/spi/tracing/VertxTracer;
            aload 3 /* options */
            invokestatic io.vertx.kafka.client.common.tracing.ConsumerTracer.create:(Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/common/tracing/ConsumerTracer;
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.tracer:Lio/vertx/kafka/client/common/tracing/ConsumerTracer;
        11: .line 111
            return
        end local 4 // io.vertx.core.impl.ContextInternal ctxInt
        end local 3 // io.vertx.kafka.client.common.KafkaClientOptions options
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   12     0      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0   12     1     vertx  Lio/vertx/core/Vertx;
            0   12     2  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0   12     3   options  Lio/vertx/kafka/client/common/KafkaClientOptions;
            9   12     4    ctxInt  Lio/vertx/core/impl/ContextInternal;
    Signature: (Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
    MethodParameters:
          Name  Flags
      vertx     
      consumer  
      options   

  private <T> void start(java.util.function.BiConsumer<org.apache.kafka.clients.consumer.Consumer<K, V>, io.vertx.core.Promise<T>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
    descriptor: (Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.function.BiConsumer task
        start local 2 // io.vertx.core.Handler handler
         0: .line 114
            aload 0 /* this */
            invokedynamic newThread()Ljava/util/concurrent/ThreadFactory;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Runnable;)Ljava/lang/Thread;
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$0(Ljava/lang/Runnable;)Ljava/lang/Thread; (6)
                  (Ljava/lang/Runnable;)Ljava/lang/Thread;
            invokestatic java.util.concurrent.Executors.newSingleThreadExecutor:(Ljava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ExecutorService;
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
         1: .line 115
            aload 0 /* this */
            aload 1 /* task */
            aload 2 /* handler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTaskWhenStarted:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         2: .line 116
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.util.function.BiConsumer task
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1     task  Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<TT;>;>;
            0    3     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<TT;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
    MethodParameters:
         Name  Flags
      task     
      handler  

  private <T> void submitTaskWhenStarted(java.util.function.BiConsumer<org.apache.kafka.clients.consumer.Consumer<K, V>, io.vertx.core.Promise<T>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
    descriptor: (Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.function.BiConsumer task
        start local 2 // io.vertx.core.Handler handler
         0: .line 119
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
            ifnonnull 2
         1: .line 120
            new java.lang.IllegalStateException
            dup
            invokespecial java.lang.IllegalStateException.<init>:()V
            athrow
         2: .line 122
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
            aload 0 /* this */
            aload 2 /* handler */
            aload 1 /* task */
            invokedynamic run(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;Ljava/util/function/BiConsumer;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$1(Lio/vertx/core/Handler;Ljava/util/function/BiConsumer;)V (7)
                  ()V
            invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
            pop
         3: .line 145
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.util.function.BiConsumer task
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1     task  Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<TT;>;>;
            0    4     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<TT;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
    MethodParameters:
         Name  Flags
      task     
      handler  

  private void pollRecords(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 148
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.polling:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 2
         1: .line 149
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
            aload 0 /* this */
            aload 1 /* handler */
            invokedynamic run(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$4(Lio/vertx/core/Handler;)V (7)
                  ()V
            invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
            pop
         2: .line 179
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  handler  Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;
    Signature: (Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  private void schedule(long);
    descriptor: (J)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // long delay
         0: .line 182
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.recordHandler:Lio/vertx/core/Handler;
            astore 3 /* handler */
        start local 3 // io.vertx.core.Handler handler
         1: .line 184
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consuming:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifeq 5
         2: .line 185
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lconst_0
            lcmp
            ifle 5
         3: .line 186
            aload 3 /* handler */
            ifnull 5
         4: .line 188
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            lload 1 /* delay */
            aload 3 /* handler */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;JLio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$7(JLio/vertx/core/Handler;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
         5: .line 196
      StackMap locals: io.vertx.core.Handler
      StackMap stack:
            return
        end local 3 // io.vertx.core.Handler handler
        end local 1 // long delay
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     1    delay  J
            1    6     3  handler  Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;
    MethodParameters:
       Name  Flags
      delay  

  private void run(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=5, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 201
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifeq 2
         1: .line 202
            return
         2: .line 205
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
            ifnull 3
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
         3: .line 207
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$9(Lorg/apache/kafka/clients/consumer/ConsumerRecords;)V (7)
                  (Lorg/apache/kafka/clients/consumer/ConsumerRecords;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pollRecords:(Lio/vertx/core/Handler;)V
         4: .line 220
            goto 15
         5: .line 222
      StackMap locals:
      StackMap stack:
            iconst_0
            istore 2 /* count */
        start local 2 // int count
         6: .line 224
            goto 13
         7: .line 228
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lstore 3 /* v */
        start local 3 // long v
         8: .line 229
            lload 3 /* v */
            lconst_0
            lcmp
            ifgt 10
         9: .line 230
            goto 14
        10: .line 231
      StackMap locals: long
      StackMap stack:
            lload 3 /* v */
            ldc 9223372036854775807
            lcmp
            ifeq 11
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
            lload 3 /* v */
            lload 3 /* v */
            lconst_1
            lsub
            invokevirtual java.util.concurrent.atomic.AtomicLong.compareAndSet:(JJ)Z
            ifeq 7
        end local 3 // long v
        11: .line 236
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.kafka.clients.consumer.ConsumerRecord
            astore 3 /* next */
        start local 3 // org.apache.kafka.clients.consumer.ConsumerRecord next
        12: .line 237
            aload 0 /* this */
            aload 1 /* handler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.tracedHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
            aload 3 /* next */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 3 // org.apache.kafka.clients.consumer.ConsumerRecord next
        13: .line 224
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
            invokeinterface java.util.Iterator.hasNext:()Z
            ifeq 14
            iload 2 /* count */
            iinc 2 /* count */ 1
            bipush 10
            if_icmplt 7
        14: .line 239
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lconst_0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
        end local 2 // int count
        15: .line 241
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   16     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0   16     1  handler  Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;
            6   15     2    count  I
            8   11     3        v  J
           12   13     3     next  Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;
    Signature: (Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  private io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> tracedHandler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 244
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.tracer:Lio/vertx/kafka/client/common/tracing/ConsumerTracer;
            ifnonnull 1
            aload 1 /* handler */
            goto 2
         1: .line 245
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* handler */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$10(Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecord;)V (7)
                  (Lorg/apache/kafka/clients/consumer/ConsumerRecord;)V
         2: .line 244
      StackMap locals:
      StackMap stack: io.vertx.core.Handler
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  handler  Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;
    Signature: (Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;)Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;
    MethodParameters:
         Name  Flags
      handler  

  protected <T> void submitTask(java.util.function.BiConsumer<org.apache.kafka.clients.consumer.Consumer<K, V>, io.vertx.core.Promise<T>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
    descriptor: (Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.function.BiConsumer task
        start local 2 // io.vertx.core.Handler handler
         0: .line 262
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 3
         1: .line 263
            aload 0 /* this */
            aload 1 /* task */
            aload 2 /* handler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.start:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         2: .line 264
            goto 4
         3: .line 265
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* task */
            aload 2 /* handler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTaskWhenStarted:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         4: .line 267
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.util.function.BiConsumer task
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     1     task  Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<TT;>;>;
            0    5     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<TT;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
    MethodParameters:
         Name  Flags
      task     
      handler  

  public io.vertx.core.Future<java.lang.Void> pause(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
         0: .line 271
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 272
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pause:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 273
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2          promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> pause(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 279
            aload 0 /* this */
            aload 1 /* topicPartitions */
            invokedynamic accept(Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$12(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 284
            aload 2 /* completionHandler */
         2: .line 279
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 286
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    4     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1    topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    4     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public void paused(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<org.apache.kafka.common.TopicPartition>>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 292
            aload 0 /* this */
            invokedynamic accept()Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$13(Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 297
            aload 1 /* handler */
         2: .line 292
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 298
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.util.Set<org.apache.kafka.common.TopicPartition>> paused();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 302
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 303
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.paused:(Lio/vertx/core/Handler;)V
         2: .line 304
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;

  public io.vertx.core.Future<java.lang.Void> resume(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
         0: .line 309
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 310
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.resume:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 311
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2          promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> resume(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 317
            aload 0 /* this */
            aload 1 /* topicPartitions */
            invokedynamic accept(Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$14(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 322
            aload 2 /* completionHandler */
         2: .line 317
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 324
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    4     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1    topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    4     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public void committed(org.apache.kafka.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<org.apache.kafka.clients.consumer.OffsetAndMetadata>>);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // io.vertx.core.Handler handler
         0: .line 330
            aload 0 /* this */
            aload 1 /* topicPartition */
            invokedynamic accept(Lorg/apache/kafka/common/TopicPartition;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$15(Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 335
            aload 2 /* handler */
         2: .line 330
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 336
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    4     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    4     2         handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      handler         

  public io.vertx.core.Future<org.apache.kafka.clients.consumer.OffsetAndMetadata> committed(org.apache.kafka.common.TopicPartition);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
         0: .line 340
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 341
            aload 0 /* this */
            aload 1 /* topicPartition */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.committed:(Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
         2: .line 342
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            1    3     2         promise  Lio/vertx/core/Promise<Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future<Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
    MethodParameters:
                Name  Flags
      topicPartition  

  public io.vertx.core.Future<java.lang.Void> seekToEnd(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
         0: .line 347
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 348
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.seekToEnd:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 349
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2          promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> seekToEnd(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 354
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* completionHandler */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$16(Ljava/util/Set;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
         1: .line 364
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1    topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    2     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public io.vertx.core.Future<java.lang.Void> seekToBeginning(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
         0: .line 369
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 370
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.seekToBeginning:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 371
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2          promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> seekToBeginning(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 376
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* completionHandler */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$18(Ljava/util/Set;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
         1: .line 386
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1    topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    2     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public io.vertx.core.Future<java.lang.Void> seek(org.apache.kafka.common.TopicPartition, long);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;J)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // long offset
         0: .line 391
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 4 /* promise */
        start local 4 // io.vertx.core.Promise promise
         1: .line 392
            aload 0 /* this */
            aload 1 /* topicPartition */
            lload 2 /* offset */
            aload 4 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.seek:(Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 393
            aload 4 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.Promise promise
        end local 2 // long offset
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    3     2          offset  J
            1    3     4         promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;J)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
                Name  Flags
      topicPartition  
      offset          

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> seek(org.apache.kafka.common.TopicPartition, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // long offset
        start local 4 // io.vertx.core.Handler completionHandler
         0: .line 398
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            aload 1 /* topicPartition */
            lload 2 /* offset */
            aload 4 /* completionHandler */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$20(Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
         1: .line 409
            aload 0 /* this */
            areturn
        end local 4 // io.vertx.core.Handler completionHandler
        end local 2 // long offset
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1     topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    2     2             offset  J
            0    2     4  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      topicPartition     
      offset             
      completionHandler  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> partitionsRevokedHandler(io.vertx.core.Handler<java.util.Set<org.apache.kafka.common.TopicPartition>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 414
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.partitionsRevokedHandler:Lio/vertx/core/Handler;
         1: .line 415
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;
    Signature: (Lio/vertx/core/Handler<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> partitionsAssignedHandler(io.vertx.core.Handler<java.util.Set<org.apache.kafka.common.TopicPartition>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 420
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.partitionsAssignedHandler:Lio/vertx/core/Handler;
         1: .line 421
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;
    Signature: (Lio/vertx/core/Handler<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.lang.Void> subscribe(java.util.Set<java.lang.String>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topics
         0: .line 426
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 427
            aload 0 /* this */
            aload 1 /* topics */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.subscribe:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 428
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topics
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1   topics  Ljava/util/Set<Ljava/lang/String;>;
            1    3     2  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/Set<Ljava/lang/String;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
        Name  Flags
      topics  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> subscribe(java.util.Set<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topics
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 434
            aload 0 /* this */
            aload 1 /* topics */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$22(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
            astore 3 /* handler */
        start local 3 // java.util.function.BiConsumer handler
         1: .line 442
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 4
         2: .line 443
            aload 0 /* this */
            aload 3 /* handler */
            aload 2 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.start:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 444
            goto 5
         4: .line 445
      StackMap locals: java.util.function.BiConsumer
      StackMap stack:
            aload 0 /* this */
            aload 3 /* handler */
            aload 2 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         5: .line 448
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 3 // java.util.function.BiConsumer handler
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Set topics
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    6     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     1             topics  Ljava/util/Set<Ljava/lang/String;>;
            0    6     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1    6     3            handler  Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/Set<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      topics             
      completionHandler  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> subscribe(java.util.regex.Pattern, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/regex/Pattern;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.regex.Pattern pattern
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 454
            aload 0 /* this */
            aload 1 /* pattern */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/regex/Pattern;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$23(Ljava/util/regex/Pattern;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
            astore 3 /* handler */
        start local 3 // java.util.function.BiConsumer handler
         1: .line 462
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 4
         2: .line 463
            aload 0 /* this */
            aload 3 /* handler */
            aload 2 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.start:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 464
            goto 5
         4: .line 465
      StackMap locals: java.util.function.BiConsumer
      StackMap stack:
            aload 0 /* this */
            aload 3 /* handler */
            aload 2 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         5: .line 468
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 3 // java.util.function.BiConsumer handler
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.regex.Pattern pattern
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    6     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     1            pattern  Ljava/util/regex/Pattern;
            0    6     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1    6     3            handler  Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/regex/Pattern;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      pattern            
      completionHandler  

  public io.vertx.core.Future<java.lang.Void> subscribe(java.util.regex.Pattern);
    descriptor: (Ljava/util/regex/Pattern;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.regex.Pattern pattern
         0: .line 473
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 474
            aload 0 /* this */
            aload 1 /* pattern */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.subscribe:(Ljava/util/regex/Pattern;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 475
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.regex.Pattern pattern
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  pattern  Ljava/util/regex/Pattern;
            1    3     2  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/regex/Pattern;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
         Name  Flags
      pattern  

  public io.vertx.core.Future<java.lang.Void> unsubscribe();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 480
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 481
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.unsubscribe:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 482
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> unsubscribe(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler completionHandler
         0: .line 488
            aload 0 /* this */
            invokedynamic accept()Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$24(Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 493
            aload 1 /* completionHandler */
         2: .line 488
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 495
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    4     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      completionHandler  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> subscription(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<java.lang.String>>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 501
            aload 0 /* this */
            invokedynamic accept()Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$25(Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 506
            aload 1 /* handler */
         2: .line 501
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 508
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Ljava/lang/String;>;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Ljava/lang/String;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.util.Set<java.lang.String>> subscription();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 513
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 514
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.subscription:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 515
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/util/Set<Ljava/lang/String;>;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Set<Ljava/lang/String;>;>;

  public io.vertx.core.Future<java.lang.Void> assign(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set partitions
         0: .line 520
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 521
            aload 0 /* this */
            aload 1 /* partitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.assign:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 522
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set partitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0        this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  partitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2     promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
            Name  Flags
      partitions  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> assign(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set partitions
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 528
            aload 0 /* this */
            aload 1 /* partitions */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$26(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
            astore 3 /* handler */
        start local 3 // java.util.function.BiConsumer handler
         1: .line 536
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 4
         2: .line 537
            aload 0 /* this */
            aload 3 /* handler */
            aload 2 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.start:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 538
            goto 5
         4: .line 539
      StackMap locals: java.util.function.BiConsumer
      StackMap stack:
            aload 0 /* this */
            aload 3 /* handler */
            aload 2 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         5: .line 542
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 3 // java.util.function.BiConsumer handler
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Set partitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    6     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     1         partitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    6     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1    6     3            handler  Ljava/util/function/BiConsumer<Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;Lio/vertx/core/Promise<Ljava/lang/Void;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      partitions         
      completionHandler  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> assignment(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<org.apache.kafka.common.TopicPartition>>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 548
            aload 0 /* this */
            invokedynamic accept()Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$27(Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 553
            aload 1 /* handler */
         2: .line 548
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 555
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.util.Set<org.apache.kafka.common.TopicPartition>> assignment();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 560
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 561
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.assignment:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 562
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> listTopics(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, java.util.List<org.apache.kafka.common.PartitionInfo>>>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 568
            aload 0 /* this */
            invokedynamic accept()Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$28(Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 573
            aload 1 /* handler */
         2: .line 568
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 575
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.util.Map<java.lang.String, java.util.List<org.apache.kafka.common.PartitionInfo>>> listTopics();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 580
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 581
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.listTopics:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            pop
         2: .line 582
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;

  public io.vertx.core.Future<java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>> commit();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 587
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 588
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.commit:(Lio/vertx/core/Handler;)V
         2: .line 589
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;
    Signature: ()Lio/vertx/core/Future<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;

  public void commit(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler completionHandler
         0: .line 594
            aload 0 /* this */
            aconst_null
            aload 1 /* completionHandler */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.commit:(Ljava/util/Map;Lio/vertx/core/Handler;)V
         1: .line 595
            return
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  public io.vertx.core.Future<java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>> commit(java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>);
    descriptor: (Ljava/util/Map;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Map offsets
         0: .line 599
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 600
            aload 0 /* this */
            aload 1 /* offsets */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.commit:(Ljava/util/Map;Lio/vertx/core/Handler;)V
         2: .line 601
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Map offsets
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  offsets  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
            1    3     2  promise  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;
    Signature: (Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;)Lio/vertx/core/Future<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;
    MethodParameters:
         Name  Flags
      offsets  

  public void commit(java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata>>>);
    descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Map offsets
        start local 2 // io.vertx.core.Handler completionHandler
         0: .line 606
            aload 0 /* this */
            aload 1 /* offsets */
            invokedynamic accept(Ljava/util/Map;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$29(Ljava/util/Map;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 617
            aload 2 /* completionHandler */
         2: .line 606
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 618
            return
        end local 2 // io.vertx.core.Handler completionHandler
        end local 1 // java.util.Map offsets
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    4     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1            offsets  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
            0    4     2  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;>;
    Signature: (Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;>;)V
    MethodParameters:
                   Name  Flags
      offsets            
      completionHandler  

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> partitionsFor(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<org.apache.kafka.common.PartitionInfo>>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.lang.String topic
        start local 2 // io.vertx.core.Handler handler
         0: .line 623
            aload 0 /* this */
            aload 1 /* topic */
            invokedynamic accept(Ljava/lang/String;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$30(Ljava/lang/String;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 628
            aload 2 /* handler */
         2: .line 623
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 630
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.lang.String topic
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1    topic  Ljava/lang/String;
            0    4     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    MethodParameters:
         Name  Flags
      topic    
      handler  

  public io.vertx.core.Future<java.util.List<org.apache.kafka.common.PartitionInfo>> partitionsFor(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.lang.String topic
         0: .line 635
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 636
            aload 0 /* this */
            aload 1 /* topic */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.partitionsFor:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            pop
         2: .line 637
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.lang.String topic
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1    topic  Ljava/lang/String;
            1    3     2  promise  Lio/vertx/core/Promise<Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;
    MethodParameters:
       Name  Flags
      topic  

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 642
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:Lio/vertx/core/Handler;
         1: .line 643
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> handler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 648
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.recordHandler:Lio/vertx/core/Handler;
         1: .line 649
            aload 0 /* this */
            lconst_0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
         2: .line 650
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  handler  Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;
    Signature: (Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;>;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> pause();
    descriptor: ()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 655
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
            lconst_0
            invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
         1: .line 656
            aload 0 /* this */
            areturn
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    Signature: ()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> resume();
    descriptor: ()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 661
            aload 0 /* this */
            ldc 9223372036854775807
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.fetch:(J)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    Signature: ()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> fetch(long);
    descriptor: (J)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // long amount
         0: .line 666
            lload 1 /* amount */
            lconst_0
            lcmp
            ifge 2
         1: .line 667
            new java.lang.IllegalArgumentException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Invalid claim "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            lload 1 /* amount */
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 670
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
            lload 1 /* amount */
            invokedynamic applyAsLong(J)Ljava/util/function/LongUnaryOperator;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (J)J
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$31(JJ)J (6)
                  (J)J
            invokevirtual java.util.concurrent.atomic.AtomicLong.updateAndGet:(Ljava/util/function/LongUnaryOperator;)J
            lstore 3 /* op */
        start local 3 // long op
         3: .line 677
            lload 3 /* op */
            lconst_0
            lcmp
            ifle 5
         4: .line 678
            aload 0 /* this */
            lconst_0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
         5: .line 680
      StackMap locals: long
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 3 // long op
        end local 1 // long amount
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0    this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     1  amount  J
            3    6     3      op  J
    Signature: (J)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    MethodParameters:
        Name  Flags
      amount  

  public long demand();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 685
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.demand:Ljava/util/concurrent/atomic/AtomicLong;
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lreturn
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;

  private io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> startConsuming();
    descriptor: ()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 689
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consuming:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         1: .line 690
            aload 0 /* this */
            lconst_0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
         2: .line 691
            aload 0 /* this */
            areturn
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    Signature: ()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;

  public io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl<K, V> endHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler endHandler
         0: .line 696
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler endHandler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0        this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    1     1  endHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    MethodParameters:
            Name  Flags
      endHandler  

  public io.vertx.core.Future<java.lang.Void> close();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 701
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 702
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.close:(Lio/vertx/core/Handler;)V
         2: .line 703
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler completionHandler
         0: .line 708
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            iconst_1
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
            ifeq 4
         1: .line 709
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
            aload 0 /* this */
            aload 1 /* completionHandler */
            invokedynamic run(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$32(Lio/vertx/core/Handler;)V (7)
                  ()V
            invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
            pop
         2: .line 718
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            invokeinterface org.apache.kafka.clients.consumer.Consumer.wakeup:()V
         3: .line 719
            goto 6
         4: .line 721
      StackMap locals:
      StackMap stack:
            aload 1 /* completionHandler */
            ifnull 6
         5: .line 722
            aload 1 /* completionHandler */
            invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         6: .line 725
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    7     0               this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    7     1  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  public void position(org.apache.kafka.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition partition
        start local 2 // io.vertx.core.Handler handler
         0: .line 729
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* partition */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lorg/apache/kafka/common/TopicPartition;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$34(Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 734
            aload 2 /* handler */
         2: .line 729
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 735
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // org.apache.kafka.common.TopicPartition partition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  partition  Lorg/apache/kafka/common/TopicPartition;
            0    4     2    handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)V
    MethodParameters:
           Name  Flags
      partition  
      handler    

  public io.vertx.core.Future<java.lang.Long> position(org.apache.kafka.common.TopicPartition);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition partition
         0: .line 739
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 740
            aload 0 /* this */
            aload 1 /* partition */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.position:(Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
         2: .line 741
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // org.apache.kafka.common.TopicPartition partition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  partition  Lorg/apache/kafka/common/TopicPartition;
            1    3     2    promise  Lio/vertx/core/Promise<Ljava/lang/Long;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future<Ljava/lang/Long;>;
    MethodParameters:
           Name  Flags
      partition  

  public void offsetsForTimes(java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndTimestamp>>>);
    descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Map topicPartitionTimestamps
        start local 2 // io.vertx.core.Handler handler
         0: .line 746
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* topicPartitionTimestamps */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Map;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$35(Ljava/util/Map;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 751
            aload 2 /* handler */
         2: .line 746
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 752
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.util.Map topicPartitionTimestamps
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0    4     0                      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartitionTimestamps  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;
            0    4     2                   handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;>;
    Signature: (Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;>;)V
    MethodParameters:
                          Name  Flags
      topicPartitionTimestamps  
      handler                   

  public io.vertx.core.Future<java.util.Map<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndTimestamp>> offsetsForTimes(java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>);
    descriptor: (Ljava/util/Map;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Map topicPartitionTimestamps
         0: .line 756
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 757
            aload 0 /* this */
            aload 1 /* topicPartitionTimestamps */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.offsetsForTimes:(Ljava/util/Map;Lio/vertx/core/Handler;)V
         2: .line 758
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Map topicPartitionTimestamps
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0    3     0                      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitionTimestamps  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;
            1    3     2                   promise  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;
    Signature: (Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;)Lio/vertx/core/Future<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;
    MethodParameters:
                          Name  Flags
      topicPartitionTimestamps  

  public void offsetsForTimes(org.apache.kafka.common.TopicPartition, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<org.apache.kafka.clients.consumer.OffsetAndTimestamp>>);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // long timestamp
        start local 4 // io.vertx.core.Handler handler
         0: .line 763
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* topicPartition */
            lload 2 /* timestamp */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lorg/apache/kafka/common/TopicPartition;J)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$36(Lorg/apache/kafka/common/TopicPartition;JLorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 771
            aload 4 /* handler */
         2: .line 763
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 772
            return
        end local 4 // io.vertx.core.Handler handler
        end local 2 // long timestamp
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    4     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    4     2       timestamp  J
            0    4     4         handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      timestamp       
      handler         

  public io.vertx.core.Future<org.apache.kafka.clients.consumer.OffsetAndTimestamp> offsetsForTimes(org.apache.kafka.common.TopicPartition, long);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;J)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // long timestamp
         0: .line 776
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 4 /* promise */
        start local 4 // io.vertx.core.Promise promise
         1: .line 777
            aload 0 /* this */
            aload 1 /* topicPartition */
            lload 2 /* timestamp */
            aload 4 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.offsetsForTimes:(Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;)V
         2: .line 778
            aload 4 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.Promise promise
        end local 2 // long timestamp
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    3     2       timestamp  J
            1    3     4         promise  Lio/vertx/core/Promise<Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;J)Lio/vertx/core/Future<Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;
    MethodParameters:
                Name  Flags
      topicPartition  
      timestamp       

  public void beginningOffsets(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
        start local 2 // io.vertx.core.Handler handler
         0: .line 783
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* topicPartitions */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$37(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 788
            aload 2 /* handler */
         2: .line 783
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 789
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    4     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    4     2          handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;>;)V
    MethodParameters:
                 Name  Flags
      topicPartitions  
      handler          

  public io.vertx.core.Future<java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>> beginningOffsets(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
         0: .line 793
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 794
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.beginningOffsets:(Ljava/util/Set;Lio/vertx/core/Handler;)V
         2: .line 795
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2          promise  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public void beginningOffsets(org.apache.kafka.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // io.vertx.core.Handler handler
         0: .line 800
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* topicPartition */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lorg/apache/kafka/common/TopicPartition;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$38(Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 807
            aload 2 /* handler */
         2: .line 800
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 808
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    4     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    4     2         handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      handler         

  public io.vertx.core.Future<java.lang.Long> beginningOffsets(org.apache.kafka.common.TopicPartition);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
         0: .line 812
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 813
            aload 0 /* this */
            aload 1 /* topicPartition */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.beginningOffsets:(Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
         2: .line 814
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            1    3     2         promise  Lio/vertx/core/Promise<Ljava/lang/Long;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future<Ljava/lang/Long;>;
    MethodParameters:
                Name  Flags
      topicPartition  

  public void endOffsets(java.util.Set<org.apache.kafka.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
        start local 2 // io.vertx.core.Handler handler
         0: .line 819
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* topicPartitions */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$39(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 824
            aload 2 /* handler */
         2: .line 819
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 825
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    4     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            0    4     2          handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;>;)V
    MethodParameters:
                 Name  Flags
      topicPartitions  
      handler          

  public io.vertx.core.Future<java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>> endOffsets(java.util.Set<org.apache.kafka.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.util.Set topicPartitions
         0: .line 829
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 830
            aload 0 /* this */
            aload 1 /* topicPartitions */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.endOffsets:(Ljava/util/Set;Lio/vertx/core/Handler;)V
         2: .line 831
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.util.Set topicPartitions
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            1    3     2          promise  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;
    Signature: (Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public void endOffsets(org.apache.kafka.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
        start local 2 // io.vertx.core.Handler handler
         0: .line 836
            aload 0 /* this */
            aload 0 /* this */
            aload 1 /* topicPartition */
            invokedynamic accept(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lorg/apache/kafka/common/TopicPartition;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$40(Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (7)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         1: .line 843
            aload 2 /* handler */
         2: .line 836
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         3: .line 844
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    4     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            0    4     2         handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      handler         

  public io.vertx.core.Future<java.lang.Long> endOffsets(org.apache.kafka.common.TopicPartition);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.common.TopicPartition topicPartition
         0: .line 848
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 849
            aload 0 /* this */
            aload 1 /* topicPartition */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.endOffsets:(Lorg/apache/kafka/common/TopicPartition;Lio/vertx/core/Handler;)V
         2: .line 850
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // org.apache.kafka.common.TopicPartition topicPartition
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0            this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  topicPartition  Lorg/apache/kafka/common/TopicPartition;
            1    3     2         promise  Lio/vertx/core/Promise<Ljava/lang/Long;>;
    Signature: (Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/core/Future<Ljava/lang/Long;>;
    MethodParameters:
                Name  Flags
      topicPartition  

  public org.apache.kafka.clients.consumer.Consumer<K, V> unwrap();
    descriptor: ()Lorg/apache/kafka/clients/consumer/Consumer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 855
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            areturn
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
    Signature: ()Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;

  public io.vertx.kafka.client.consumer.KafkaReadStream batchHandler(io.vertx.core.Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 859
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.batchHandler:Lio/vertx/core/Handler;
         1: .line 860
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  handler  Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;
    Signature: (Lio/vertx/core/Handler<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.kafka.client.consumer.KafkaReadStream<K, V> pollTimeout(java.time.Duration);
    descriptor: (Ljava/time/Duration;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.time.Duration timeout
         0: .line 865
            aload 0 /* this */
            aload 1 /* timeout */
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pollTimeout:Ljava/time/Duration;
         1: .line 866
            aload 0 /* this */
            areturn
        end local 1 // java.time.Duration timeout
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  timeout  Ljava/time/Duration;
    Signature: (Ljava/time/Duration;)Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      timeout  final

  public void poll(java.time.Duration, io.vertx.core.Handler<io.vertx.core.AsyncResult<org.apache.kafka.clients.consumer.ConsumerRecords<K, V>>>);
    descriptor: (Ljava/time/Duration;Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.time.Duration timeout
        start local 2 // io.vertx.core.Handler handler
         0: .line 871
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
            aload 0 /* this */
            aload 1 /* timeout */
            aload 2 /* handler */
            invokedynamic run(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Ljava/time/Duration;Lio/vertx/core/Handler;)Ljava/lang/Runnable;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$41(Ljava/time/Duration;Lio/vertx/core/Handler;)V (7)
                  ()V
            invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
            pop
         1: .line 883
            return
        end local 2 // io.vertx.core.Handler handler
        end local 1 // java.time.Duration timeout
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     1  timeout  Ljava/time/Duration;
            0    2     2  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;>;
    Signature: (Ljava/time/Duration;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;>;)V
    MethodParameters:
         Name  Flags
      timeout  final
      handler  final

  public io.vertx.core.Future<org.apache.kafka.clients.consumer.ConsumerRecords<K, V>> poll(java.time.Duration);
    descriptor: (Ljava/time/Duration;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.time.Duration timeout
         0: .line 887
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 888
            aload 0 /* this */
            aload 1 /* timeout */
            aload 2 /* promise */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.poll:(Ljava/time/Duration;Lio/vertx/core/Handler;)V
         2: .line 889
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.time.Duration timeout
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1  timeout  Ljava/time/Duration;
            1    3     2  promise  Lio/vertx/core/Promise<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;
    Signature: (Ljava/time/Duration;)Lio/vertx/core/Future<Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;>;
    MethodParameters:
         Name  Flags
      timeout  final

  public io.vertx.core.streams.ReadStream pause();
    descriptor: ()Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pause:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream pause();
    descriptor: ()Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pause:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast io.vertx.core.Handler
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream handler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast io.vertx.core.Handler
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream endHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream partitionsFor(java.lang.String, io.vertx.core.Handler);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
         0: .line 1
            aload 0
            aload 1
            aload 2
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.partitionsFor:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream resume();
    descriptor: ()Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.resume:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream resume();
    descriptor: ()Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
         0: .line 1
            aload 0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.resume:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream fetch(long);
    descriptor: (J)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
         0: .line 1
            aload 0
            lload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.fetch:(J)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream fetch(long);
    descriptor: (J)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
         0: .line 1
            aload 0
            lload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.fetch:(J)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.StreamBase exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/StreamBase;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.kafka.client.consumer.KafkaReadStream exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static java.lang.Thread lambda$0(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)Ljava/lang/Thread;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=6, locals=1, args_size=1
        start local 0 // java.lang.Runnable r
         0: .line 114
            new java.lang.Thread
            dup
            aload 0 /* r */
            new java.lang.StringBuilder
            dup
            ldc "vert.x-kafka-consumer-thread-"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            getstatic io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.threadCount:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial java.lang.Thread.<init>:(Ljava/lang/Runnable;Ljava/lang/String;)V
            areturn
        end local 0 // java.lang.Runnable r
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     r  Ljava/lang/Runnable;

  private void lambda$1(io.vertx.core.Handler, java.util.function.BiConsumer);
    descriptor: (Lio/vertx/core/Handler;Ljava/util/function/BiConsumer;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 123
            aconst_null
            astore 3 /* future */
        start local 3 // io.vertx.core.Promise future
         1: .line 124
            aload 1
            ifnull 4
         2: .line 125
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 3 /* future */
         3: .line 126
            aload 3 /* future */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 0 /* this */
            aload 1
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$2(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         4: .line 135
      StackMap locals: io.vertx.core.Promise
      StackMap stack:
            aload 2
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 3 /* future */
            invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
         5: .line 136
            goto 11
      StackMap locals:
      StackMap stack: java.lang.Exception
         6: astore 4 /* e */
        start local 4 // java.lang.Exception e
         7: .line 137
            aload 3 /* future */
            ifnull 9
         8: .line 138
            aload 3 /* future */
            aload 4 /* e */
            invokeinterface io.vertx.core.Promise.tryFail:(Ljava/lang/Throwable;)Z
            pop
         9: .line 140
      StackMap locals: java.lang.Exception
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 11
        10: .line 141
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:Lio/vertx/core/Handler;
            aload 4 /* e */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 4 // java.lang.Exception e
        end local 3 // io.vertx.core.Promise future
        11: .line 144
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   12     0    this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1   11     3  future  Lio/vertx/core/Promise<TT;>;
            7   11     4       e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           4     5       6  Class java.lang.Exception

  private void lambda$4(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=5, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 150
            iconst_0
            istore 2 /* submitted */
        start local 2 // boolean submitted
         1: .line 152
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifne 16
         2: .line 154
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.pollTimeout:Ljava/time/Duration;
            invokeinterface org.apache.kafka.clients.consumer.Consumer.poll:(Ljava/time/Duration;)Lorg/apache/kafka/clients/consumer/ConsumerRecords;
            astore 3 /* records */
        start local 3 // org.apache.kafka.clients.consumer.ConsumerRecords records
         3: .line 155
            aload 3 /* records */
            ifnull 16
            aload 3 /* records */
            invokevirtual org.apache.kafka.clients.consumer.ConsumerRecords.count:()I
            ifle 16
         4: .line 156
            iconst_1
            istore 2 /* submitted */
         5: .line 157
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            aload 1
            aload 3 /* records */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecords;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$6(Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecords;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
        end local 3 // org.apache.kafka.clients.consumer.ConsumerRecords records
         6: .line 162
            goto 16
      StackMap locals: io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl io.vertx.core.Handler int
      StackMap stack: org.apache.kafka.common.errors.WakeupException
         7: pop
            goto 16
         8: .line 163
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 3 /* e */
        start local 3 // java.lang.Exception e
         9: .line 164
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:Lio/vertx/core/Handler;
            ifnull 16
        10: .line 165
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.exceptionHandler:Lio/vertx/core/Handler;
            aload 3 /* e */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        end local 3 // java.lang.Exception e
        11: .line 169
            goto 16
      StackMap locals:
      StackMap stack: java.lang.Throwable
        12: astore 4
        13: .line 170
            iload 2 /* submitted */
            ifne 15
        14: .line 171
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$5(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
        15: .line 176
      StackMap locals: io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl io.vertx.core.Handler int top java.lang.Throwable
      StackMap stack:
            aload 4
            athrow
        16: .line 170
      StackMap locals: io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl io.vertx.core.Handler int
      StackMap stack:
            iload 2 /* submitted */
            ifne 18
        17: .line 171
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$5(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
        end local 2 // boolean submitted
        18: .line 177
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   19     0       this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            1   18     2  submitted  Z
            3    6     3    records  Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;
            9   11     3          e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           2     6       7  Class org.apache.kafka.common.errors.WakeupException
           2     6       8  Class java.lang.Exception
           1    12      12  any

  private void lambda$7(long, io.vertx.core.Handler, java.lang.Void);
    descriptor: (JLio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 4 // java.lang.Void v1
         0: .line 189
            lload 1
            lconst_0
            lcmp
            ifle 3
         1: .line 190
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            invokeinterface io.vertx.core.Context.owner:()Lio/vertx/core/Vertx;
            lload 1
            aload 0 /* this */
            aload 3
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$8(Lio/vertx/core/Handler;Ljava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
            pop2
         2: .line 191
            goto 4
         3: .line 192
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.run:(Lio/vertx/core/Handler;)V
         4: .line 194
      StackMap locals:
      StackMap stack:
            return
        end local 4 // java.lang.Void v1
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     4    v1  Ljava/lang/Void;

  private void lambda$9(org.apache.kafka.clients.consumer.ConsumerRecords);
    descriptor: (Lorg/apache/kafka/clients/consumer/ConsumerRecords;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // org.apache.kafka.clients.consumer.ConsumerRecords records
         0: .line 209
            aload 1 /* records */
            ifnull 6
            aload 1 /* records */
            invokevirtual org.apache.kafka.clients.consumer.ConsumerRecords.count:()I
            ifle 6
         1: .line 210
            aload 0 /* this */
            aload 1 /* records */
            invokevirtual org.apache.kafka.clients.consumer.ConsumerRecords.iterator:()Ljava/util/Iterator;
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
         2: .line 211
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.batchHandler:Lio/vertx/core/Handler;
            ifnull 4
         3: .line 212
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.batchHandler:Lio/vertx/core/Handler;
            aload 1 /* records */
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         4: .line 214
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lconst_0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
         5: .line 215
            goto 7
         6: .line 216
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            lconst_1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
         7: .line 218
      StackMap locals:
      StackMap stack:
            return
        end local 1 // org.apache.kafka.clients.consumer.ConsumerRecords records
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    8     1  records  Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;

  private void lambda$10(io.vertx.core.Handler, org.apache.kafka.clients.consumer.ConsumerRecord);
    descriptor: (Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecord;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.ConsumerRecord rec
         0: .line 246
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            checkcast io.vertx.core.impl.ContextInternal
            invokeinterface io.vertx.core.impl.ContextInternal.duplicate:()Lio/vertx/core/impl/ContextInternal;
            astore 3 /* ctx */
        start local 3 // io.vertx.core.impl.ContextInternal ctx
         1: .line 247
            aload 3 /* ctx */
            aload 0 /* this */
            aload 3 /* ctx */
            aload 2 /* rec */
            aload 1
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/impl/ContextInternal;Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$11(Lio/vertx/core/impl/ContextInternal;Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.impl.ContextInternal.emit:(Lio/vertx/core/Handler;)V
        end local 3 // io.vertx.core.impl.ContextInternal ctx
         2: .line 257
            return
        end local 2 // org.apache.kafka.clients.consumer.ConsumerRecord rec
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     2   rec  Lorg/apache/kafka/clients/consumer/ConsumerRecord<TK;TV;>;
            1    2     3   ctx  Lio/vertx/core/impl/ContextInternal;

  private static void lambda$12(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 280
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.pause:(Ljava/util/Collection;)V
         1: .line 281
            aload 2 /* future */
            ifnull 3
         2: .line 282
            aload 2 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 284
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     2    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$13(org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 1 // io.vertx.core.Promise future
         0: .line 293
            aload 0 /* consumer */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.paused:()Ljava/util/Set;
            astore 2 /* result */
        start local 2 // java.util.Set result
         1: .line 294
            aload 1 /* future */
            ifnull 3
         2: .line 295
            aload 1 /* future */
            aload 2 /* result */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 2 // java.util.Set result
         3: .line 297
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise future
        end local 0 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     1    future  Lio/vertx/core/Promise<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;
            1    3     2    result  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;

  private static void lambda$14(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 318
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.resume:(Ljava/util/Collection;)V
         1: .line 319
            aload 2 /* future */
            ifnull 3
         2: .line 320
            aload 2 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 322
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     2    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$15(org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 331
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.committed:(Lorg/apache/kafka/common/TopicPartition;)Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;
            astore 3 /* result */
        start local 3 // org.apache.kafka.clients.consumer.OffsetAndMetadata result
         1: .line 332
            aload 2 /* future */
            ifnull 3
         2: .line 333
            aload 2 /* future */
            aload 3 /* result */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 3 // org.apache.kafka.clients.consumer.OffsetAndMetadata result
         3: .line 335
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     2    future  Lio/vertx/core/Promise<Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
            1    3     3    result  Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;

  private void lambda$16(java.util.Set, io.vertx.core.Handler, java.lang.Void);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 3 // java.lang.Void r
         0: .line 355
            aload 0 /* this */
            aconst_null
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
         1: .line 357
            aload 0 /* this */
            aload 1
            invokedynamic accept(Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$17(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         2: .line 362
            aload 2
         3: .line 357
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         4: .line 363
            return
        end local 3 // java.lang.Void r
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     3     r  Ljava/lang/Void;

  private void lambda$18(java.util.Set, io.vertx.core.Handler, java.lang.Void);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 3 // java.lang.Void r
         0: .line 377
            aload 0 /* this */
            aconst_null
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
         1: .line 379
            aload 0 /* this */
            aload 1
            invokedynamic accept(Ljava/util/Set;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$19(Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         2: .line 384
            aload 2
         3: .line 379
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         4: .line 385
            return
        end local 3 // java.lang.Void r
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     3     r  Ljava/lang/Void;

  private void lambda$20(org.apache.kafka.common.TopicPartition, long, io.vertx.core.Handler, java.lang.Void);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;JLio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=6, args_size=5
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 5 // java.lang.Void r
         0: .line 399
            aload 0 /* this */
            aconst_null
            putfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.current:Ljava/util/Iterator;
         1: .line 401
            aload 0 /* this */
            aload 1
            lload 2
            invokedynamic accept(Lorg/apache/kafka/common/TopicPartition;J)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$21(Lorg/apache/kafka/common/TopicPartition;JLorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V (6)
                  (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
         2: .line 406
            aload 4
         3: .line 401
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.submitTask:(Ljava/util/function/BiConsumer;Lio/vertx/core/Handler;)V
         4: .line 407
            return
        end local 5 // java.lang.Void r
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     5     r  Ljava/lang/Void;

  private void lambda$22(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 435
            aload 2 /* consumer */
            aload 1
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.rebalanceListener:Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;
            invokeinterface org.apache.kafka.clients.consumer.Consumer.subscribe:(Ljava/util/Collection;Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;)V
         1: .line 436
            aload 0 /* this */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.startConsuming:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            pop
         2: .line 437
            aload 3 /* future */
            ifnull 4
         3: .line 438
            aload 3 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         4: .line 440
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     2  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    5     3    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private void lambda$23(java.util.regex.Pattern, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/regex/Pattern;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 455
            aload 2 /* consumer */
            aload 1
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.rebalanceListener:Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;
            invokeinterface org.apache.kafka.clients.consumer.Consumer.subscribe:(Ljava/util/regex/Pattern;Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;)V
         1: .line 456
            aload 0 /* this */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.startConsuming:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            pop
         2: .line 457
            aload 3 /* future */
            ifnull 4
         3: .line 458
            aload 3 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         4: .line 460
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     2  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    5     3    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$24(org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 1 // io.vertx.core.Promise future
         0: .line 489
            aload 0 /* consumer */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.unsubscribe:()V
         1: .line 490
            aload 1 /* future */
            ifnull 3
         2: .line 491
            aload 1 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 493
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise future
        end local 0 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     1    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$25(org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 1 // io.vertx.core.Promise future
         0: .line 502
            aload 0 /* consumer */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.subscription:()Ljava/util/Set;
            astore 2 /* subscription */
        start local 2 // java.util.Set subscription
         1: .line 503
            aload 1 /* future */
            ifnull 3
         2: .line 504
            aload 1 /* future */
            aload 2 /* subscription */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 2 // java.util.Set subscription
         3: .line 506
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise future
        end local 0 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    4     0      consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     1        future  Lio/vertx/core/Promise<Ljava/util/Set<Ljava/lang/String;>;>;
            1    3     2  subscription  Ljava/util/Set<Ljava/lang/String;>;

  private void lambda$26(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 529
            aload 2 /* consumer */
            aload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.assign:(Ljava/util/Collection;)V
         1: .line 530
            aload 0 /* this */
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.startConsuming:()Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;
            pop
         2: .line 531
            aload 3 /* future */
            ifnull 4
         3: .line 532
            aload 3 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         4: .line 534
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    5     2  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    5     3    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$27(org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 1 // io.vertx.core.Promise future
         0: .line 549
            aload 0 /* consumer */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.assignment:()Ljava/util/Set;
            astore 2 /* partitions */
        start local 2 // java.util.Set partitions
         1: .line 550
            aload 1 /* future */
            ifnull 3
         2: .line 551
            aload 1 /* future */
            aload 2 /* partitions */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 2 // java.util.Set partitions
         3: .line 553
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise future
        end local 0 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0    consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     1      future  Lio/vertx/core/Promise<Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;>;
            1    3     2  partitions  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;

  private static void lambda$28(org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 1 // io.vertx.core.Promise future
         0: .line 569
            aload 0 /* consumer */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.listTopics:()Ljava/util/Map;
            astore 2 /* topics */
        start local 2 // java.util.Map topics
         1: .line 570
            aload 1 /* future */
            ifnull 3
         2: .line 571
            aload 1 /* future */
            aload 2 /* topics */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 2 // java.util.Map topics
         3: .line 573
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.Promise future
        end local 0 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     1    future  Lio/vertx/core/Promise<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;>;
            1    3     2    topics  Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;

  private static void lambda$29(java.util.Map, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Map;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 608
            aload 0
            ifnonnull 3
         1: .line 609
            aload 1 /* consumer */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.commitSync:()V
         2: .line 610
            goto 4
         3: .line 611
      StackMap locals:
      StackMap stack:
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.commitSync:(Ljava/util/Map;)V
         4: .line 613
      StackMap locals:
      StackMap stack:
            aload 2 /* future */
            ifnull 6
         5: .line 614
            aload 2 /* future */
            aload 0
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         6: .line 617
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    7     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    7     2    future  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;>;

  private static void lambda$30(java.lang.String, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/lang/String;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 624
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.partitionsFor:(Ljava/lang/String;)Ljava/util/List;
            astore 3 /* partitions */
        start local 3 // java.util.List partitions
         1: .line 625
            aload 2 /* future */
            ifnull 3
         2: .line 626
            aload 2 /* future */
            aload 3 /* partitions */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 3 // java.util.List partitions
         3: .line 628
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     1    consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     2      future  Lio/vertx/core/Promise<Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;
            1    3     3  partitions  Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;

  private static long lambda$31(long, long);
    descriptor: (JJ)J
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=2
        start local 2 // long val
         0: .line 671
            lload 2 /* val */
            lload 0
            ladd
            lstore 2 /* val */
         1: .line 672
            lload 2 /* val */
            lconst_0
            lcmp
            ifge 3
         2: .line 673
            ldc 9223372036854775807
            lstore 2 /* val */
         3: .line 675
      StackMap locals:
      StackMap stack:
            lload 2 /* val */
            lreturn
        end local 2 // long val
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     2   val  J

  private void lambda$32(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 710
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            invokeinterface org.apache.kafka.clients.consumer.Consumer.close:()V
         1: .line 711
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 0 /* this */
            aload 1
            invokedynamic handle(Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$33(Lio/vertx/core/Handler;Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
         2: .line 717
            return
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;

  private void lambda$34(org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=6, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 730
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.position:(Lorg/apache/kafka/common/TopicPartition;)J
            lstore 4 /* pos */
        start local 4 // long pos
         1: .line 731
            aload 3 /* future */
            ifnull 3
         2: .line 732
            aload 3 /* future */
            lload 4 /* pos */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 4 // long pos
         3: .line 734
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     2  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     3    future  Lio/vertx/core/Promise<Ljava/lang/Long;>;
            1    3     4       pos  J

  private void lambda$35(java.util.Map, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Map;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 747
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.offsetsForTimes:(Ljava/util/Map;)Ljava/util/Map;
            astore 4 /* offsetsForTimes */
        start local 4 // java.util.Map offsetsForTimes
         1: .line 748
            aload 3 /* future */
            ifnull 3
         2: .line 749
            aload 3 /* future */
            aload 4 /* offsetsForTimes */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 4 // java.util.Map offsetsForTimes
         3: .line 751
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    4     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     2         consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     3           future  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;>;
            1    3     4  offsetsForTimes  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;

  private void lambda$36(org.apache.kafka.common.TopicPartition, long, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;JLorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=8, args_size=5
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 4 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 5 // io.vertx.core.Promise future
         0: .line 764
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 6 /* input */
        start local 6 // java.util.Map input
         1: .line 765
            aload 6 /* input */
            aload 1
            lload 2
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 767
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 6 /* input */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.offsetsForTimes:(Ljava/util/Map;)Ljava/util/Map;
            astore 7 /* offsetsForTimes */
        start local 7 // java.util.Map offsetsForTimes
         3: .line 768
            aload 5 /* future */
            ifnull 5
         4: .line 769
            aload 5 /* future */
            aload 7 /* offsetsForTimes */
            aload 1
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.kafka.clients.consumer.OffsetAndTimestamp
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 7 // java.util.Map offsetsForTimes
        end local 6 // java.util.Map input
         5: .line 771
      StackMap locals:
      StackMap stack:
            return
        end local 5 // io.vertx.core.Promise future
        end local 4 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0             this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     4         consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    6     5           future  Lio/vertx/core/Promise<Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;
            1    5     6            input  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;
            3    5     7  offsetsForTimes  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndTimestamp;>;

  private void lambda$37(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 784
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.beginningOffsets:(Ljava/util/Collection;)Ljava/util/Map;
            astore 4 /* beginningOffsets */
        start local 4 // java.util.Map beginningOffsets
         1: .line 785
            aload 3 /* future */
            ifnull 3
         2: .line 786
            aload 3 /* future */
            aload 4 /* beginningOffsets */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 4 // java.util.Map beginningOffsets
         3: .line 788
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0              this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     2          consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     3            future  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;
            1    3     4  beginningOffsets  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;

  private void lambda$38(org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=6, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 801
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 4 /* input */
        start local 4 // java.util.Set input
         1: .line 802
            aload 4 /* input */
            aload 1
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         2: .line 803
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 4 /* input */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.beginningOffsets:(Ljava/util/Collection;)Ljava/util/Map;
            astore 5 /* beginningOffsets */
        start local 5 // java.util.Map beginningOffsets
         3: .line 804
            aload 3 /* future */
            ifnull 5
         4: .line 805
            aload 3 /* future */
            aload 5 /* beginningOffsets */
            aload 1
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.Long
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 5 // java.util.Map beginningOffsets
        end local 4 // java.util.Set input
         5: .line 807
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    6     0              this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     2          consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    6     3            future  Lio/vertx/core/Promise<Ljava/lang/Long;>;
            1    5     4             input  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            3    5     5  beginningOffsets  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;

  private void lambda$39(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 820
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.endOffsets:(Ljava/util/Collection;)Ljava/util/Map;
            astore 4 /* endOffsets */
        start local 4 // java.util.Map endOffsets
         1: .line 821
            aload 3 /* future */
            ifnull 3
         2: .line 822
            aload 3 /* future */
            aload 4 /* endOffsets */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 4 // java.util.Map endOffsets
         3: .line 824
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     2    consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     3      future  Lio/vertx/core/Promise<Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;>;
            1    3     4  endOffsets  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;

  private void lambda$40(org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=6, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 3 // io.vertx.core.Promise future
         0: .line 837
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 4 /* input */
        start local 4 // java.util.Set input
         1: .line 838
            aload 4 /* input */
            aload 1
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         2: .line 839
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 4 /* input */
            invokeinterface org.apache.kafka.clients.consumer.Consumer.endOffsets:(Ljava/util/Collection;)Ljava/util/Map;
            astore 5 /* endOffsets */
        start local 5 // java.util.Map endOffsets
         3: .line 840
            aload 3 /* future */
            ifnull 5
         4: .line 841
            aload 3 /* future */
            aload 5 /* endOffsets */
            aload 1
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.Long
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 5 // java.util.Map endOffsets
        end local 4 // java.util.Set input
         5: .line 843
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Promise future
        end local 2 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    6     0        this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    6     2    consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    6     3      future  Lio/vertx/core/Promise<Ljava/lang/Long;>;
            1    5     4       input  Ljava/util/Set<Lorg/apache/kafka/common/TopicPartition;>;
            3    5     5  endOffsets  Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Ljava/lang/Long;>;

  private void lambda$41(java.time.Duration, io.vertx.core.Handler);
    descriptor: (Ljava/time/Duration;Lio/vertx/core/Handler;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
         0: .line 872
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.closed:Ljava/util/concurrent/atomic/AtomicBoolean;
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
            ifne 8
         1: .line 874
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.consumer:Lorg/apache/kafka/clients/consumer/Consumer;
            aload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.poll:(Ljava/time/Duration;)Lorg/apache/kafka/clients/consumer/ConsumerRecords;
            astore 3 /* records */
        start local 3 // org.apache.kafka.clients.consumer.ConsumerRecords records
         2: .line 875
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 2
            aload 3 /* records */
            invokedynamic handle(Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecords;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$42(Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecords;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
        end local 3 // org.apache.kafka.clients.consumer.ConsumerRecords records
         3: .line 876
            goto 8
      StackMap locals:
      StackMap stack: org.apache.kafka.common.errors.WakeupException
         4: pop
         5: .line 877
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 2
            invokedynamic handle(Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$43(Lio/vertx/core/Handler;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
            goto 8
         6: .line 878
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 3 /* e */
        start local 3 // java.lang.Exception e
         7: .line 879
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 2
            aload 3 /* e */
            invokedynamic handle(Lio/vertx/core/Handler;Ljava/lang/Exception;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$44(Lio/vertx/core/Handler;Ljava/lang/Exception;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
        end local 3 // java.lang.Exception e
         8: .line 882
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0     this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            2    3     3  records  Lorg/apache/kafka/clients/consumer/ConsumerRecords<TK;TV;>;
            7    8     3        e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           1     3       4  Class org.apache.kafka.common.errors.WakeupException
           1     3       6  Class java.lang.Exception

  private void lambda$2(io.vertx.core.Handler, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // io.vertx.core.AsyncResult event
         0: .line 129
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.context:Lio/vertx/core/Context;
            aload 1
            aload 2 /* event */
            invokedynamic handle(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.lambda$3(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
         1: .line 132
            return
        end local 2 // io.vertx.core.AsyncResult event
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    2     2  event  Lio/vertx/core/AsyncResult<TT;>;

  private void lambda$6(io.vertx.core.Handler, org.apache.kafka.clients.consumer.ConsumerRecords, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecords;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=4
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 3 // java.lang.Void v
         0: .line 158
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.polling:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         1: .line 159
            aload 1
            aload 2
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         2: .line 160
            return
        end local 3 // java.lang.Void v
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     3     v  Ljava/lang/Void;

  private void lambda$5(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 1 // java.lang.Void v
         0: .line 172
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.polling:Ljava/util/concurrent/atomic/AtomicBoolean;
            iconst_0
            invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
         1: .line 173
            aload 0 /* this */
            lconst_0
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.schedule:(J)V
         2: .line 174
            return
        end local 1 // java.lang.Void v
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    3     1     v  Ljava/lang/Void;

  private void lambda$8(io.vertx.core.Handler, java.lang.Long);
    descriptor: (Lio/vertx/core/Handler;Ljava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // java.lang.Long v2
         0: .line 190
            aload 0 /* this */
            aload 1
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.run:(Lio/vertx/core/Handler;)V
            return
        end local 2 // java.lang.Long v2
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    1     2    v2  Ljava/lang/Long;

  private void lambda$11(io.vertx.core.impl.ContextInternal, org.apache.kafka.clients.consumer.ConsumerRecord, io.vertx.core.Handler, java.lang.Void);
    descriptor: (Lio/vertx/core/impl/ContextInternal;Lorg/apache/kafka/clients/consumer/ConsumerRecord;Lio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=7, args_size=5
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 4 // java.lang.Void v
         0: .line 248
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.tracer:Lio/vertx/kafka/client/common/tracing/ConsumerTracer;
            aload 1
            aload 2
            invokevirtual io.vertx.kafka.client.common.tracing.ConsumerTracer.prepareMessageReceived:(Lio/vertx/core/Context;Lorg/apache/kafka/clients/consumer/ConsumerRecord;)Lio/vertx/kafka/client/common/tracing/ConsumerTracer$StartedSpan;
            astore 5 /* startedSpan */
        start local 5 // io.vertx.kafka.client.common.tracing.ConsumerTracer$StartedSpan startedSpan
         1: .line 250
            aload 3
            aload 2
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         2: .line 251
            aload 5 /* startedSpan */
            aload 1
            invokevirtual io.vertx.kafka.client.common.tracing.ConsumerTracer$StartedSpan.finish:(Lio/vertx/core/Context;)V
         3: .line 252
            goto 7
      StackMap locals: io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl io.vertx.core.impl.ContextInternal org.apache.kafka.clients.consumer.ConsumerRecord io.vertx.core.Handler java.lang.Void io.vertx.kafka.client.common.tracing.ConsumerTracer$StartedSpan
      StackMap stack: java.lang.Throwable
         4: astore 6 /* t */
        start local 6 // java.lang.Throwable t
         5: .line 253
            aload 5 /* startedSpan */
            aload 1
            aload 6 /* t */
            invokevirtual io.vertx.kafka.client.common.tracing.ConsumerTracer$StartedSpan.fail:(Lio/vertx/core/Context;Ljava/lang/Throwable;)V
         6: .line 254
            aload 6 /* t */
            athrow
        end local 6 // java.lang.Throwable t
        end local 5 // io.vertx.kafka.client.common.tracing.ConsumerTracer$StartedSpan startedSpan
         7: .line 256
      StackMap locals:
      StackMap stack:
            return
        end local 4 // java.lang.Void v
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0         this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    8     4            v  Ljava/lang/Void;
            1    7     5  startedSpan  Lio/vertx/kafka/client/common/tracing/ConsumerTracer$StartedSpan;
            5    7     6            t  Ljava/lang/Throwable;
      Exception table:
        from    to  target  type
           1     3       4  Class java.lang.Throwable

  private static void lambda$17(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 358
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.seekToEnd:(Ljava/util/Collection;)V
         1: .line 359
            aload 2 /* future */
            ifnull 3
         2: .line 360
            aload 2 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 362
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     2    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$19(java.util.Set, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Ljava/util/Set;Lorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 2 // io.vertx.core.Promise future
         0: .line 380
            aload 1 /* consumer */
            aload 0
            invokeinterface org.apache.kafka.clients.consumer.Consumer.seekToBeginning:(Ljava/util/Collection;)V
         1: .line 381
            aload 2 /* future */
            ifnull 3
         2: .line 382
            aload 2 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 384
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     2    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private static void lambda$21(org.apache.kafka.common.TopicPartition, long, org.apache.kafka.clients.consumer.Consumer, io.vertx.core.Promise);
    descriptor: (Lorg/apache/kafka/common/TopicPartition;JLorg/apache/kafka/clients/consumer/Consumer;Lio/vertx/core/Promise;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=5, args_size=4
        start local 3 // org.apache.kafka.clients.consumer.Consumer consumer
        start local 4 // io.vertx.core.Promise future
         0: .line 402
            aload 3 /* consumer */
            aload 0
            lload 1
            invokeinterface org.apache.kafka.clients.consumer.Consumer.seek:(Lorg/apache/kafka/common/TopicPartition;J)V
         1: .line 403
            aload 4 /* future */
            ifnull 3
         2: .line 404
            aload 4 /* future */
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 406
      StackMap locals:
      StackMap stack:
            return
        end local 4 // io.vertx.core.Promise future
        end local 3 // org.apache.kafka.clients.consumer.Consumer consumer
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     3  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            0    4     4    future  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private void lambda$33(io.vertx.core.Handler, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
        start local 2 // java.lang.Void v
         0: .line 712
            aload 0 /* this */
            getfield io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl.worker:Ljava/util/concurrent/ExecutorService;
            invokeinterface java.util.concurrent.ExecutorService.shutdownNow:()Ljava/util/List;
            pop
         1: .line 713
            aload 1
            ifnull 3
         2: .line 714
            aload 1
            invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         3: .line 716
      StackMap locals:
      StackMap stack:
            return
        end local 2 // java.lang.Void v
        end local 0 // io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl<TK;TV;>;
            0    4     2     v  Ljava/lang/Void;

  private static void lambda$42(io.vertx.core.Handler, org.apache.kafka.clients.consumer.ConsumerRecords, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Lorg/apache/kafka/clients/consumer/ConsumerRecords;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Void v
         0: .line 875
            aload 0
            aload 1
            invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
            return
        end local 2 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     2     v  Ljava/lang/Void;

  private static void lambda$43(io.vertx.core.Handler, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // java.lang.Void v
         0: .line 877
            aload 0
            invokestatic org.apache.kafka.clients.consumer.ConsumerRecords.empty:()Lorg/apache/kafka/clients/consumer/ConsumerRecords;
            invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
            return
        end local 1 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     v  Ljava/lang/Void;

  private static void lambda$44(io.vertx.core.Handler, java.lang.Exception, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Ljava/lang/Exception;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Void v
         0: .line 879
            aload 0
            aload 1
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
            return
        end local 2 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     2     v  Ljava/lang/Void;

  private static void lambda$3(io.vertx.core.Handler, io.vertx.core.AsyncResult, java.lang.Void);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Void v
         0: .line 130
            aload 0
            aload 1
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         1: .line 131
            return
        end local 2 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     2     v  Ljava/lang/Void;
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
SourceFile: "KafkaReadStreamImpl.java"
NestMembers:
  io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl$1
InnerClasses:
  public StartedSpan = io.vertx.kafka.client.common.tracing.ConsumerTracer$StartedSpan of io.vertx.kafka.client.common.tracing.ConsumerTracer
  io.vertx.kafka.client.consumer.impl.KafkaReadStreamImpl$1
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
/

io.vertx/ vertx-kafka-client/ 4.0.0/ io/vertx/kafka/client/consumer/impl/KafkaReadStreamImpl.class
