public class examples.VertxKafkaClientExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.VertxKafkaClientExamples
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // examples.VertxKafkaClientExamples this
         0: .line 48
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/VertxKafkaClientExamples;

  public void exampleCreateConsumerJava(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 56
            new java.util.Properties
            dup
            invokespecial java.util.Properties.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Properties config
         1: .line 57
            aload 2 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 58
            aload 2 /* config */
            ldc "key.deserializer"
            ldc Lorg/apache/kafka/common/serialization/StringDeserializer;
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 59
            aload 2 /* config */
            ldc "value.deserializer"
            ldc Lorg/apache/kafka/common/serialization/StringDeserializer;
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 60
            aload 2 /* config */
            ldc "group.id"
            ldc "my_group"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 61
            aload 2 /* config */
            ldc "auto.offset.reset"
            ldc "earliest"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 62
            aload 2 /* config */
            ldc "enable.auto.commit"
            ldc "false"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         7: .line 65
            aload 1 /* vertx */
            aload 2 /* config */
            invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         8: .line 66
            return
        end local 2 // java.util.Properties config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    9     0    this  Lexamples/VertxKafkaClientExamples;
            0    9     1   vertx  Lio/vertx/core/Vertx;
            1    9     2  config  Ljava/util/Properties;
    MethodParameters:
       Name  Flags
      vertx  

  public void exampleCreateConsumer(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 74
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 75
            aload 2 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 76
            aload 2 /* config */
            ldc "key.deserializer"
            ldc "org.apache.kafka.common.serialization.StringDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 77
            aload 2 /* config */
            ldc "value.deserializer"
            ldc "org.apache.kafka.common.serialization.StringDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 78
            aload 2 /* config */
            ldc "group.id"
            ldc "my_group"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 79
            aload 2 /* config */
            ldc "auto.offset.reset"
            ldc "earliest"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 80
            aload 2 /* config */
            ldc "enable.auto.commit"
            ldc "false"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         7: .line 83
            aload 1 /* vertx */
            aload 2 /* config */
            invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         8: .line 84
            return
        end local 2 // java.util.Map config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    9     0    this  Lexamples/VertxKafkaClientExamples;
            0    9     1   vertx  Lio/vertx/core/Vertx;
            1    9     2  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void createProducer(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 88
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 89
            aload 2 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 90
            aload 2 /* config */
            ldc "key.serializer"
            ldc "org.apache.kafka.common.serialization.StringSerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 91
            aload 2 /* config */
            ldc "value.serializer"
            ldc "org.apache.kafka.common.serialization.StringSerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 92
            aload 2 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 95
            aload 1 /* vertx */
            aload 2 /* config */
            invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
         6: .line 96
            return
        end local 2 // java.util.Map config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lexamples/VertxKafkaClientExamples;
            0    7     1   vertx  Lio/vertx/core/Vertx;
            1    7     2  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void createProducerJava(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 104
            new java.util.Properties
            dup
            invokespecial java.util.Properties.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Properties config
         1: .line 105
            aload 2 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 106
            aload 2 /* config */
            ldc "acks"
            ldc "1"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 109
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Ljava/lang/String;
            ldc Ljava/lang/String;
            invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
         4: .line 110
            return
        end local 2 // java.util.Properties config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lexamples/VertxKafkaClientExamples;
            0    5     1   vertx  Lio/vertx/core/Vertx;
            1    5     2  config  Ljava/util/Properties;
    MethodParameters:
       Name  Flags
      vertx  

  public void exampleSubscribe(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 114
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$0(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
                  (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 120
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topics */
        start local 2 // java.util.Set topics
         2: .line 121
            aload 2 /* topics */
            ldc "topic1"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 122
            aload 2 /* topics */
            ldc "topic2"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         4: .line 123
            aload 2 /* topics */
            ldc "topic3"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         5: .line 124
            aload 1 /* consumer */
            aload 2 /* topics */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/Set;)Lio/vertx/core/Future;
            pop
         6: .line 127
            ldc "topic\\d"
            invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
            astore 3 /* pattern */
        start local 3 // java.util.regex.Pattern pattern
         7: .line 128
            aload 1 /* consumer */
            aload 3 /* pattern */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/regex/Pattern;)Lio/vertx/core/Future;
            pop
         8: .line 131
            aload 1 /* consumer */
            ldc "a-single-topic"
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
            pop
         9: .line 132
            return
        end local 3 // java.util.regex.Pattern pattern
        end local 2 // java.util.Set topics
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lexamples/VertxKafkaClientExamples;
            0   10     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            2   10     2    topics  Ljava/util/Set<Ljava/lang/String;>;
            7   10     3   pattern  Ljava/util/regex/Pattern;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleSubscribeWithResult(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 136
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$1(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
                  (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 142
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topics */
        start local 2 // java.util.Set topics
         2: .line 143
            aload 2 /* topics */
            ldc "topic1"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 144
            aload 2 /* topics */
            ldc "topic2"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         4: .line 145
            aload 2 /* topics */
            ldc "topic3"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         5: .line 146
            aload 1 /* consumer */
         6: .line 147
            aload 2 /* topics */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/Set;)Lio/vertx/core/Future;
         7: .line 148
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$2(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         8: .line 150
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$3(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         9: .line 155
            aload 1 /* consumer */
        10: .line 156
            ldc "a-single-topic"
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
        11: .line 157
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$4(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
        12: .line 159
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$5(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
        13: .line 162
            return
        end local 2 // java.util.Set topics
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   14     0      this  Lexamples/VertxKafkaClientExamples;
            0   14     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            2   14     2    topics  Ljava/util/Set<Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerPartitionsNotifs(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 171
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$6(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
                  (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 177
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$7(Ljava/util/Set;)V (6)
                  (Ljava/util/Set;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsAssignedHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         2: .line 184
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$8(Ljava/util/Set;)V (6)
                  (Ljava/util/Set;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsRevokedHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         3: .line 192
            aload 1 /* consumer */
         4: .line 193
            ldc "test"
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
         5: .line 194
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$9(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         6: .line 196
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$10(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 199
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lexamples/VertxKafkaClientExamples;
            0    8     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleUnsubscribe(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 205
            aload 1 /* consumer */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe:()Lio/vertx/core/Future;
            pop
         1: .line 206
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lexamples/VertxKafkaClientExamples;
            0    2     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleUnsubscribeWithCallback(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 217
            aload 1 /* consumer */
         1: .line 218
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe:()Lio/vertx/core/Future;
         2: .line 219
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$11(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 222
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lexamples/VertxKafkaClientExamples;
            0    4     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerAssignPartition(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 231
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$12(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
                  (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 237
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topicPartitions */
        start local 2 // java.util.Set topicPartitions
         2: .line 238
            aload 2 /* topicPartitions */
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         3: .line 239
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         4: .line 240
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         5: .line 238
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         6: .line 243
            aload 1 /* consumer */
         7: .line 244
            aload 2 /* topicPartitions */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.assign:(Ljava/util/Set;)Lio/vertx/core/Future;
         8: .line 245
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$13(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         9: .line 247
            aload 1 /* consumer */
            invokedynamic apply(Lio/vertx/kafka/client/consumer/KafkaConsumer;)Ljava/util/function/Function;
              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;
                  examples/VertxKafkaClientExamples.lambda$14(Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)Lio/vertx/core/Future; (6)
                  (Ljava/lang/Void;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.compose:(Ljava/util/function/Function;)Lio/vertx/core/Future;
        10: .line 248
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$15(Ljava/util/Set;)V (6)
                  (Ljava/util/Set;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
        11: .line 253
            return
        end local 2 // java.util.Set topicPartitions
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   12     0             this  Lexamples/VertxKafkaClientExamples;
            0   12     1         consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            2   12     2  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerPartitionsFor(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 263
            aload 1 /* consumer */
         1: .line 264
            ldc "test"
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsFor:(Ljava/lang/String;)Lio/vertx/core/Future;
         2: .line 265
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$16(Ljava/util/List;)V (6)
                  (Ljava/util/List;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 270
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lexamples/VertxKafkaClientExamples;
            0    4     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerListTopics(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 274
            aload 1 /* consumer */
         1: .line 275
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.listTopics:()Lio/vertx/core/Future;
         2: .line 276
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$17(Ljava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 282
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lexamples/VertxKafkaClientExamples;
            0    4     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerWithPoll(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 294
            aload 2 /* consumer */
         1: .line 295
            ldc "test"
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
         2: .line 296
            aload 1 /* vertx */
            aload 2 /* consumer */
            invokedynamic handle(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;)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
                  examples/VertxKafkaClientExamples.lambda$19(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 319
            return
        end local 2 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lexamples/VertxKafkaClientExamples;
            0    4     1     vertx  Lio/vertx/core/Vertx;
            0    4     2  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      vertx     
      consumer  

  public void exampleProducerPartitionsFor(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 323
            aload 1 /* producer */
         1: .line 324
            ldc "test"
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.partitionsFor:(Ljava/lang/String;)Lio/vertx/core/Future;
         2: .line 325
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$23(Ljava/util/List;)V (6)
                  (Ljava/util/List;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 328
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lexamples/VertxKafkaClientExamples;
            0    4     1  producer  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      producer  

  public void exampleConsumerManualOffsetCommit(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 339
            aload 1 /* consumer */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.commit:()Lio/vertx/core/Future;
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$25(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 342
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lexamples/VertxKafkaClientExamples;
            0    2     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleSeek(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 345
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 346
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 347
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 345
            astore 2 /* topicPartition */
        start local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 350
            aload 1 /* consumer */
         5: .line 351
            aload 2 /* topicPartition */
            ldc 10
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seek:(Lio/vertx/kafka/client/common/TopicPartition;J)Lio/vertx/core/Future;
         6: .line 352
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$26(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 354
            return
        end local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    8     0            this  Lexamples/VertxKafkaClientExamples;
            0    8     1        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    8     2  topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleSeekToBeginning(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 357
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 358
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 359
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 357
            astore 2 /* topicPartition */
        start local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 362
            aload 1 /* consumer */
         5: .line 363
            aload 2 /* topicPartition */
            invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seekToBeginning:(Ljava/util/Set;)Lio/vertx/core/Future;
         6: .line 364
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$27(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 365
            return
        end local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    8     0            this  Lexamples/VertxKafkaClientExamples;
            0    8     1        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    8     2  topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleSeekToEnd(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 373
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 374
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 375
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 373
            astore 2 /* topicPartition */
        start local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 378
            aload 1 /* consumer */
         5: .line 379
            aload 2 /* topicPartition */
            invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seekToEnd:(Ljava/util/Set;)Lio/vertx/core/Future;
         6: .line 380
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$28(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 381
            return
        end local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    8     0            this  Lexamples/VertxKafkaClientExamples;
            0    8     1        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    8     2  topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerBeginningOffsets(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 390
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topicPartitions */
        start local 2 // java.util.Set topicPartitions
         1: .line 391
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
            astore 3 /* topicPartition */
        start local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
         2: .line 392
            aload 2 /* topicPartitions */
            aload 3 /* topicPartition */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 394
            aload 1 /* consumer */
         4: .line 395
            aload 2 /* topicPartitions */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets:(Ljava/util/Set;)Lio/vertx/core/Future;
         5: .line 396
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$29(Ljava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         6: .line 406
            aload 1 /* consumer */
         7: .line 407
            aload 3 /* topicPartition */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
         8: .line 408
            aload 3 /* topicPartition */
            invokedynamic handle(Lio/vertx/kafka/client/common/TopicPartition;)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
                  examples/VertxKafkaClientExamples.lambda$31(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         9: .line 414
            return
        end local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 2 // java.util.Set topicPartitions
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lexamples/VertxKafkaClientExamples;
            0   10     1         consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            1   10     2  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            2   10     3   topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerEndOffsets(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 422
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topicPartitions */
        start local 2 // java.util.Set topicPartitions
         1: .line 423
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
            astore 3 /* topicPartition */
        start local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
         2: .line 424
            aload 2 /* topicPartitions */
            aload 3 /* topicPartition */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 426
            aload 1 /* consumer */
            aload 2 /* topicPartitions */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets:(Ljava/util/Set;)Lio/vertx/core/Future;
         4: .line 427
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$32(Ljava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         5: .line 437
            aload 1 /* consumer */
         6: .line 438
            aload 3 /* topicPartition */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
         7: .line 439
            aload 3 /* topicPartition */
            invokedynamic handle(Lio/vertx/kafka/client/common/TopicPartition;)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
                  examples/VertxKafkaClientExamples.lambda$34(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         8: .line 445
            return
        end local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 2 // java.util.Set topicPartitions
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    9     0             this  Lexamples/VertxKafkaClientExamples;
            0    9     1         consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            1    9     2  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            2    9     3   topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerOffsetsForTimes(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=6, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 454
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* topicPartitionsWithTimestamps */
        start local 2 // java.util.Map topicPartitionsWithTimestamps
         1: .line 455
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
            astore 3 /* topicPartition */
        start local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
         2: .line 458
            invokestatic java.lang.System.currentTimeMillis:()J
            ldc 60000
            lsub
            lstore 4 /* timestamp */
        start local 4 // long timestamp
         3: .line 460
            aload 2 /* topicPartitionsWithTimestamps */
            aload 3 /* topicPartition */
            lload 4 /* timestamp */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 461
            aload 1 /* consumer */
         5: .line 462
            aload 2 /* topicPartitionsWithTimestamps */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes:(Ljava/util/Map;)Lio/vertx/core/Future;
         6: .line 463
            lload 4 /* timestamp */
            invokedynamic handle(J)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
                  examples/VertxKafkaClientExamples.lambda$35(JLjava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 475
            aload 1 /* consumer */
            aload 3 /* topicPartition */
            lload 4 /* timestamp */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes:(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)Lio/vertx/core/Future;
            aload 3 /* topicPartition */
            lload 4 /* timestamp */
            invokedynamic handle(Lio/vertx/kafka/client/common/TopicPartition;J)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
                  examples/VertxKafkaClientExamples.lambda$37(Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V (6)
                  (Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         8: .line 483
            return
        end local 4 // long timestamp
        end local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 2 // java.util.Map topicPartitionsWithTimestamps
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot                           Name  Signature
            0    9     0                           this  Lexamples/VertxKafkaClientExamples;
            0    9     1                       consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            1    9     2  topicPartitionsWithTimestamps  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;
            2    9     3                 topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
            3    9     4                      timestamp  J
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleConsumerFlowControl(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 492
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 493
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 494
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 492
            astore 3 /* topicPartition */
        start local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 497
            aload 2 /* consumer */
            aload 2 /* consumer */
            aload 3 /* topicPartition */
            aload 1 /* vertx */
            invokedynamic handle(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Vertx;)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
                  examples/VertxKafkaClientExamples.lambda$38(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
                  (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         5: .line 513
            return
        end local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
        end local 2 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    6     0            this  Lexamples/VertxKafkaClientExamples;
            0    6     1           vertx  Lio/vertx/core/Vertx;
            0    6     2        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    6     3  topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
    Signature: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      vertx     
      consumer  

  public void exampleConsumerClose(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 517
            aload 1 /* consumer */
         1: .line 518
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.close:()Lio/vertx/core/Future;
         2: .line 519
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$42(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         3: .line 520
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$43(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         4: .line 521
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lexamples/VertxKafkaClientExamples;
            0    5     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleProducerWrite(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 524
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 6
         2: .line 528
      StackMap locals: int
      StackMap stack:
            ldc "test"
            new java.lang.StringBuilder
            dup
            ldc "message_"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* i */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
         3: .line 527
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         4: .line 530
            aload 1 /* producer */
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
            pop
        end local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 524
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            iconst_5
            if_icmplt 2
        end local 2 // int i
         7: .line 532
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lexamples/VertxKafkaClientExamples;
            0    8     1  producer  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
            1    7     2         i  I
            4    5     3    record  Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      producer  

  public void exampleProducerWriteWithAck(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 540
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 6
         2: .line 544
      StackMap locals: int
      StackMap stack:
            ldc "test"
            new java.lang.StringBuilder
            dup
            ldc "message_"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* i */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
         3: .line 543
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         4: .line 546
            aload 1 /* producer */
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.send:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Future;
            aload 3 /* record */
            invokedynamic handle(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)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
                  examples/VertxKafkaClientExamples.lambda$44(Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/kafka/client/producer/RecordMetadata;)V (6)
                  (Lio/vertx/kafka/client/producer/RecordMetadata;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
        end local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 540
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            iconst_5
            if_icmplt 2
        end local 2 // int i
         7: .line 555
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lexamples/VertxKafkaClientExamples;
            0    8     1  producer  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
            1    7     2         i  I
            4    5     3    record  Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      producer  

  public void exampleProducerWriteWithSpecificPartition(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 563
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 6
         2: .line 567
      StackMap locals: int
      StackMap stack:
            ldc "test"
            aconst_null
            new java.lang.StringBuilder
            dup
            ldc "message_"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* i */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            iconst_0
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Integer;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
         3: .line 566
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         4: .line 569
            aload 1 /* producer */
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
            pop
        end local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 563
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            bipush 10
            if_icmplt 2
        end local 2 // int i
         7: .line 571
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lexamples/VertxKafkaClientExamples;
            0    8     1  producer  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
            1    7     2         i  I
            4    5     3    record  Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      producer  

  public void exampleProducerWriteWithSpecificKey(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 580
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 7
         2: .line 583
      StackMap locals: int
      StackMap stack:
            iload 2 /* i */
            iconst_2
            irem
            istore 3 /* key */
        start local 3 // int key
         3: .line 587
            ldc "test"
            iload 3 /* key */
            invokestatic java.lang.String.valueOf:(I)Ljava/lang/String;
            new java.lang.StringBuilder
            dup
            ldc "message_"
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            iload 2 /* i */
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
         4: .line 586
            astore 4 /* record */
        start local 4 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 589
            aload 1 /* producer */
            aload 4 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
            pop
        end local 4 // io.vertx.kafka.client.producer.KafkaProducerRecord record
        end local 3 // int key
         6: .line 580
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         7: iload 2 /* i */
            bipush 10
            if_icmplt 2
        end local 2 // int i
         8: .line 591
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    9     0      this  Lexamples/VertxKafkaClientExamples;
            0    9     1  producer  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
            1    8     2         i  I
            3    6     3       key  I
            5    6     4    record  Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      producer  

  public void exampleSharedProducer(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // java.util.Map config
         0: .line 595
            aload 1 /* vertx */
            ldc "the-producer"
            aload 2 /* config */
            invokestatic io.vertx.kafka.client.producer.KafkaProducer.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaProducer;
            astore 3 /* producer1 */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducer producer1
         1: .line 598
            aload 3 /* producer1 */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.close:()Lio/vertx/core/Future;
            pop
         2: .line 599
            return
        end local 3 // io.vertx.kafka.client.producer.KafkaProducer producer1
        end local 2 // java.util.Map config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lexamples/VertxKafkaClientExamples;
            0    3     1      vertx  Lio/vertx/core/Vertx;
            0    3     2     config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            1    3     3  producer1  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
        Name  Flags
      vertx   
      config  

  public void exampleProducerClose(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 602
            aload 1 /* producer */
         1: .line 603
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.close:()Lio/vertx/core/Future;
         2: .line 604
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$45(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         3: .line 605
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$46(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         4: .line 606
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lexamples/VertxKafkaClientExamples;
            0    5     1  producer  Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      producer  

  public void exampleErrorHandling(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 616
            aload 1 /* consumer */
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$47(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 619
            return
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lexamples/VertxKafkaClientExamples;
            0    2     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  public void exampleUsingVertxDeserializers();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // examples.VertxKafkaClientExamples this
         0: .line 623
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        start local 1 // java.util.Map config
         1: .line 624
            aload 1 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 625
            aload 1 /* config */
            ldc "key.deserializer"
            ldc "io.vertx.kafka.client.serialization.BufferDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 626
            aload 1 /* config */
            ldc "value.deserializer"
            ldc "io.vertx.kafka.client.serialization.BufferDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 627
            aload 1 /* config */
            ldc "group.id"
            ldc "my_group"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 628
            aload 1 /* config */
            ldc "auto.offset.reset"
            ldc "earliest"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         6: .line 629
            aload 1 /* config */
            ldc "enable.auto.commit"
            ldc "false"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         7: .line 632
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
         8: .line 633
            aload 1 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         9: .line 634
            aload 1 /* config */
            ldc "key.deserializer"
            ldc "io.vertx.kafka.client.serialization.JsonObjectDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        10: .line 635
            aload 1 /* config */
            ldc "value.deserializer"
            ldc "io.vertx.kafka.client.serialization.JsonObjectDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        11: .line 636
            aload 1 /* config */
            ldc "group.id"
            ldc "my_group"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        12: .line 637
            aload 1 /* config */
            ldc "auto.offset.reset"
            ldc "earliest"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        13: .line 638
            aload 1 /* config */
            ldc "enable.auto.commit"
            ldc "false"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        14: .line 641
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        15: .line 642
            aload 1 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        16: .line 643
            aload 1 /* config */
            ldc "key.deserializer"
            ldc "io.vertx.kafka.client.serialization.JsonArrayDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        17: .line 644
            aload 1 /* config */
            ldc "value.deserializer"
            ldc "io.vertx.kafka.client.serialization.JsonArrayDeserializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        18: .line 645
            aload 1 /* config */
            ldc "group.id"
            ldc "my_group"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        19: .line 646
            aload 1 /* config */
            ldc "auto.offset.reset"
            ldc "earliest"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        20: .line 647
            aload 1 /* config */
            ldc "enable.auto.commit"
            ldc "false"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        21: .line 648
            return
        end local 1 // java.util.Map config
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   22     0    this  Lexamples/VertxKafkaClientExamples;
            1   22     1  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;

  public void exampleUsingVertxSerializers();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // examples.VertxKafkaClientExamples this
         0: .line 652
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        start local 1 // java.util.Map config
         1: .line 653
            aload 1 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 654
            aload 1 /* config */
            ldc "key.serializer"
            ldc "io.vertx.kafka.client.serialization.BufferSerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 655
            aload 1 /* config */
            ldc "value.serializer"
            ldc "io.vertx.kafka.client.serialization.BufferSerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 656
            aload 1 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 659
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
         6: .line 660
            aload 1 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         7: .line 661
            aload 1 /* config */
            ldc "key.serializer"
            ldc "io.vertx.kafka.client.serialization.JsonObjectSerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         8: .line 662
            aload 1 /* config */
            ldc "value.serializer"
            ldc "io.vertx.kafka.client.serialization.JsonObjectSerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         9: .line 663
            aload 1 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        10: .line 666
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        11: .line 667
            aload 1 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        12: .line 668
            aload 1 /* config */
            ldc "key.serializer"
            ldc "io.vertx.kafka.client.serialization.JsonArraySerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        13: .line 669
            aload 1 /* config */
            ldc "value.serializer"
            ldc "io.vertx.kafka.client.serialization.JsonArraySerializer"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        14: .line 670
            aload 1 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        15: .line 671
            return
        end local 1 // java.util.Map config
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   16     0    this  Lexamples/VertxKafkaClientExamples;
            1   16     1  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;

  public void exampleUsingVertxDeserializers2(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 674
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 675
            aload 2 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 676
            aload 2 /* config */
            ldc "group.id"
            ldc "my_group"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 677
            aload 2 /* config */
            ldc "auto.offset.reset"
            ldc "earliest"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 678
            aload 2 /* config */
            ldc "enable.auto.commit"
            ldc "false"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 681
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Lio/vertx/core/buffer/Buffer;
            ldc Lio/vertx/core/buffer/Buffer;
            invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         6: .line 684
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Lio/vertx/core/json/JsonObject;
            ldc Lio/vertx/core/json/JsonObject;
            invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         7: .line 687
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Lio/vertx/core/json/JsonArray;
            ldc Lio/vertx/core/json/JsonArray;
            invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         8: .line 688
            return
        end local 2 // java.util.Map config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    9     0    this  Lexamples/VertxKafkaClientExamples;
            0    9     1   vertx  Lio/vertx/core/Vertx;
            1    9     2  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
    MethodParameters:
       Name  Flags
      vertx  

  public void exampleUsingVertxSerializers2(io.vertx.core.Vertx);
    descriptor: (Lio/vertx/core/Vertx;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 691
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 692
            aload 2 /* config */
            ldc "bootstrap.servers"
            ldc "localhost:9092"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 693
            aload 2 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 696
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Lio/vertx/core/buffer/Buffer;
            ldc Lio/vertx/core/buffer/Buffer;
            invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
         4: .line 699
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Lio/vertx/core/json/JsonObject;
            ldc Lio/vertx/core/json/JsonObject;
            invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
         5: .line 702
            aload 1 /* vertx */
            aload 2 /* config */
            ldc Lio/vertx/core/json/JsonArray;
            ldc Lio/vertx/core/json/JsonArray;
            invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
         6: .line 703
            return
        end local 2 // java.util.Map config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lexamples/VertxKafkaClientExamples;
            0    7     1   vertx  Lio/vertx/core/Vertx;
            1    7     2  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
    MethodParameters:
       Name  Flags
      vertx  

  private static void lambda$0(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 115
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Processing key="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ",value="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 116
            ldc ",partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ",offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 115
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 117
            return
        end local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$1(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 137
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Processing key="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ",value="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 138
            ldc ",partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ",offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 137
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 139
            return
        end local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$2(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 149
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$3(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 151
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Could not subscribe "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* cause */
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$4(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 158
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$5(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 160
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Could not subscribe "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* cause */
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$6(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 172
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Processing key="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ",value="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 173
            ldc ",partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ",offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 172
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 174
            return
        end local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$7(java.util.Set);
    descriptor: (Ljava/util/Set;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // java.util.Set topicPartitions
         0: .line 178
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Partitions assigned"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 179
            aload 0 /* topicPartitions */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 2
            goto 4
      StackMap locals: java.util.Set top java.util.Iterator
      StackMap stack:
         2: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.common.TopicPartition
            astore 1 /* topicPartition */
        start local 1 // io.vertx.kafka.client.common.TopicPartition topicPartition
         3: .line 180
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            aload 1 /* topicPartition */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* topicPartition */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 1 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 179
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 182
            return
        end local 0 // java.util.Set topicPartitions
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            3    4     1   topicPartition  Lio/vertx/kafka/client/common/TopicPartition;

  private static void lambda$8(java.util.Set);
    descriptor: (Ljava/util/Set;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // java.util.Set topicPartitions
         0: .line 185
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Partitions revoked"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 186
            aload 0 /* topicPartitions */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 2
            goto 4
      StackMap locals: java.util.Set top java.util.Iterator
      StackMap stack:
         2: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.common.TopicPartition
            astore 1 /* topicPartition */
        start local 1 // io.vertx.kafka.client.common.TopicPartition topicPartition
         3: .line 187
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            aload 1 /* topicPartition */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* topicPartition */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 1 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 186
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 189
            return
        end local 0 // java.util.Set topicPartitions
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            3    4     1   topicPartition  Lio/vertx/kafka/client/common/TopicPartition;

  private static void lambda$9(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 195
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$10(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 197
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Could not subscribe "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* cause */
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$11(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 220
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer unsubscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$12(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 232
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "key="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ",value="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 233
            ldc ",partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ",offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 232
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 234
            return
        end local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0  record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$13(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 245
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Partition assigned"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static io.vertx.core.Future lambda$14(io.vertx.kafka.client.consumer.KafkaConsumer, java.lang.Void);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)Lio/vertx/core/Future;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=2, args_size=2
        start local 1 // java.lang.Void v
         0: .line 247
            aload 0
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.assignment:()Lio/vertx/core/Future;
            areturn
        end local 1 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     v  Ljava/lang/Void;

  private static void lambda$15(java.util.Set);
    descriptor: (Ljava/util/Set;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // java.util.Set partitions
         0: .line 249
            aload 0 /* partitions */
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 2
            goto 3
      StackMap locals: java.util.Set top java.util.Iterator
      StackMap stack:
         1: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.common.TopicPartition
            astore 1 /* topicPartition */
        start local 1 // io.vertx.kafka.client.common.TopicPartition topicPartition
         2: .line 250
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            aload 1 /* topicPartition */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            ldc " "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* topicPartition */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 1 // io.vertx.kafka.client.common.TopicPartition topicPartition
         3: .line 249
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 252
            return
        end local 0 // java.util.Set partitions
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    5     0      partitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            2    3     1  topicPartition  Lio/vertx/kafka/client/common/TopicPartition;

  private static void lambda$16(java.util.List);
    descriptor: (Ljava/util/List;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // java.util.List partitions
         0: .line 266
            aload 0 /* partitions */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 2
            goto 3
      StackMap locals: java.util.List top java.util.Iterator
      StackMap stack:
         1: aload 2
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.common.PartitionInfo
            astore 1 /* partitionInfo */
        start local 1 // io.vertx.kafka.client.common.PartitionInfo partitionInfo
         2: .line 267
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            aload 1 /* partitionInfo */
            invokevirtual java.io.PrintStream.println:(Ljava/lang/Object;)V
        end local 1 // io.vertx.kafka.client.common.PartitionInfo partitionInfo
         3: .line 266
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         4: .line 269
            return
        end local 0 // java.util.List partitions
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0     partitions  Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;
            2    3     1  partitionInfo  Lio/vertx/kafka/client/common/PartitionInfo;

  private static void lambda$17(java.util.Map);
    descriptor: (Ljava/util/Map;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.Map partitionsTopicMap
         0: .line 277
            aload 0 /* partitionsTopicMap */
            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
                  examples/VertxKafkaClientExamples.lambda$18(Ljava/lang/String;Ljava/util/List;)V (6)
                  (Ljava/lang/String;Ljava/util/List;)V
            invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
         1: .line 280
            return
        end local 0 // java.util.Map partitionsTopicMap
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    2     0  partitionsTopicMap  Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;

  private static void lambda$19(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer, java.lang.Void);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=5, locals=3, args_size=3
        start local 2 // java.lang.Void v
         0: .line 297
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 300
            aload 0
            ldc 1000
            aload 1
            aload 0
            invokedynamic handle(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/Vertx;)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
                  examples/VertxKafkaClientExamples.lambda$20(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/Vertx;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
            pop2
         2: .line 318
            return
        end local 2 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     2     v  Ljava/lang/Void;

  private static void lambda$23(java.util.List);
    descriptor: (Ljava/util/List;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.util.List partitions
         0: .line 326
            aload 0 /* partitions */
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Ljava/io/PrintStream;)Ljava/util/function/Consumer;
              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
                  java/io/PrintStream.println(Ljava/lang/Object;)V (5)
                  (Lio/vertx/kafka/client/common/PartitionInfo;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
            return
        end local 0 // java.util.List partitions
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    1     0  partitions  Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;

  private static void lambda$25(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 340
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Last read message offset committed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$26(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 352
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Seeking done"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$27(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 364
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Seeking done"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$28(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 380
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Seeking done"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$29(java.util.Map);
    descriptor: (Ljava/util/Map;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.Map results
         0: .line 397
            aload 0 /* results */
            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
                  examples/VertxKafkaClientExamples.lambda$30(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
                  (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
            invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
         1: .line 402
            return
        end local 0 // java.util.Map results
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  results  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;

  private static void lambda$31(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 1 // java.lang.Long beginningOffset
         0: .line 409
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 410
            new java.lang.StringBuilder
            dup
            ldc "Beginning offset for topic="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 411
            aload 0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ", beginningOffset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* beginningOffset */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         3: .line 410
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 409
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 412
            return
        end local 1 // java.lang.Long beginningOffset
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     1  beginningOffset  Ljava/lang/Long;

  private static void lambda$32(java.util.Map);
    descriptor: (Ljava/util/Map;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.Map results
         0: .line 428
            aload 0 /* results */
            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
                  examples/VertxKafkaClientExamples.lambda$33(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
                  (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
            invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
         1: .line 433
            return
        end local 0 // java.util.Map results
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  results  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;

  private static void lambda$34(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 1 // java.lang.Long endOffset
         0: .line 440
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 441
            new java.lang.StringBuilder
            dup
            ldc "End offset for topic="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 442
            aload 0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ", endOffset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* endOffset */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         3: .line 441
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 440
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 443
            return
        end local 1 // java.lang.Long endOffset
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     1  endOffset  Ljava/lang/Long;

  private static void lambda$35(long, java.util.Map);
    descriptor: (JLjava/util/Map;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=2
        start local 2 // java.util.Map results
         0: .line 464
            aload 2 /* results */
            lload 0
            invokedynamic accept(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
                  examples/VertxKafkaClientExamples.lambda$36(JLio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V (6)
                  (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
            invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
         1: .line 471
            return
        end local 2 // java.util.Map results
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     2  results  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;

  private static void lambda$37(io.vertx.kafka.client.common.TopicPartition, long, io.vertx.kafka.client.consumer.OffsetAndTimestamp);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=3
        start local 3 // io.vertx.kafka.client.consumer.OffsetAndTimestamp offsetAndTimestamp
         0: .line 476
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 477
            new java.lang.StringBuilder
            dup
            ldc "Offset for topic="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 478
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc "\n"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         3: .line 479
            ldc ", timestamp="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            lload 1
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            ldc ", offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* offsetAndTimestamp */
            invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getOffset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         4: .line 480
            ldc ", offsetTimestamp="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* offsetAndTimestamp */
            invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getTimestamp:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         5: .line 477
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         6: .line 476
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         7: .line 481
            return
        end local 3 // io.vertx.kafka.client.consumer.OffsetAndTimestamp offsetAndTimestamp
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    8     3  offsetAndTimestamp  Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;

  private static void lambda$38(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumerRecord);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
        start local 3 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 498
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "key="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ",value="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         1: .line 499
            ldc ",partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ",offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 498
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 502
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            ifne 7
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            ldc 5
            lcmp
            ifne 7
         4: .line 505
            aload 0
            aload 1
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.pause:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
         5: .line 506
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$39(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         6: .line 507
            aload 2
            aload 0
            aload 1
            invokedynamic handle(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;)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
                  examples/VertxKafkaClientExamples.lambda$40(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 512
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     3  record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$42(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 519
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer is now closed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$43(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 520
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Close failed: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* cause */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$44(io.vertx.kafka.client.producer.KafkaProducerRecord, io.vertx.kafka.client.producer.RecordMetadata);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/kafka/client/producer/RecordMetadata;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 1 // io.vertx.kafka.client.producer.RecordMetadata recordMetadata
         0: .line 547
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 548
            new java.lang.StringBuilder
            dup
            ldc "Message "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0
            invokeinterface io.vertx.kafka.client.producer.KafkaProducerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " written on topic="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* recordMetadata */
            invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 549
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* recordMetadata */
            invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
         3: .line 550
            ldc ", offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* recordMetadata */
            invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getOffset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         4: .line 548
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         5: .line 547
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         6: .line 551
            return
        end local 1 // io.vertx.kafka.client.producer.RecordMetadata recordMetadata
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    7     1  recordMetadata  Lio/vertx/kafka/client/producer/RecordMetadata;

  private static void lambda$45(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 604
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Producer is now closed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$46(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 605
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Close failed: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* cause */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$47(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.lang.Throwable e
         0: .line 617
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Error = "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* e */
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 618
            return
        end local 0 // java.lang.Throwable e
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0     e  Ljava/lang/Throwable;

  private static void lambda$18(java.lang.String, java.util.List);
    descriptor: (Ljava/lang/String;Ljava/util/List;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // java.lang.String topic
        start local 1 // java.util.List partitions
         0: .line 278
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "topic = "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* topic */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 279
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "partitions = "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* partitions */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 280
            return
        end local 1 // java.util.List partitions
        end local 0 // java.lang.String topic
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     0       topic  Ljava/lang/String;
            0    3     1  partitions  Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;

  private static void lambda$20(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.core.Vertx, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/Vertx;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 2 // java.lang.Long timerId
         0: .line 301
            aload 0
         1: .line 302
            ldc 100
            invokestatic java.time.Duration.ofMillis:(J)Ljava/time/Duration;
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.poll:(Ljava/time/Duration;)Lio/vertx/core/Future;
         2: .line 303
            invokedynamic handle()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
                  examples/VertxKafkaClientExamples.lambda$21(Lio/vertx/kafka/client/consumer/KafkaConsumerRecords;)V (6)
                  (Lio/vertx/kafka/client/consumer/KafkaConsumerRecords;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         3: .line 310
            aload 1
            aload 2 /* timerId */
            invokedynamic handle(Lio/vertx/core/Vertx;Ljava/lang/Long;)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
                  examples/VertxKafkaClientExamples.lambda$22(Lio/vertx/core/Vertx;Ljava/lang/Long;Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         4: .line 316
            return
        end local 2 // java.lang.Long timerId
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     2  timerId  Ljava/lang/Long;

  private static void lambda$30(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.common.TopicPartition topic
        start local 1 // java.lang.Long beginningOffset
         0: .line 398
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 399
            new java.lang.StringBuilder
            dup
            ldc "Beginning offset for topic="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* topic */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 400
            aload 0 /* topic */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ", beginningOffset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* beginningOffset */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         3: .line 399
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 398
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 401
            return
        end local 1 // java.lang.Long beginningOffset
        end local 0 // io.vertx.kafka.client.common.TopicPartition topic
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0            topic  Lio/vertx/kafka/client/common/TopicPartition;
            0    6     1  beginningOffset  Ljava/lang/Long;

  private static void lambda$33(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.kafka.client.common.TopicPartition topic
        start local 1 // java.lang.Long beginningOffset
         0: .line 429
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 430
            new java.lang.StringBuilder
            dup
            ldc "End offset for topic="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* topic */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 431
            aload 0 /* topic */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ", beginningOffset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* beginningOffset */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         3: .line 430
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 429
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 432
            return
        end local 1 // java.lang.Long beginningOffset
        end local 0 // io.vertx.kafka.client.common.TopicPartition topic
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     0            topic  Lio/vertx/kafka/client/common/TopicPartition;
            0    6     1  beginningOffset  Ljava/lang/Long;

  private static void lambda$36(long, io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndTimestamp);
    descriptor: (JLio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=3
        start local 2 // io.vertx.kafka.client.common.TopicPartition topic
        start local 3 // io.vertx.kafka.client.consumer.OffsetAndTimestamp offset
         0: .line 465
            getstatic java.lang.System.out:Ljava/io/PrintStream;
         1: .line 466
            new java.lang.StringBuilder
            dup
            ldc "Offset for topic="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* topic */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 467
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* topic */
            invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc "\n"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         3: .line 468
            ldc ", timestamp="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            lload 0
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            ldc ", offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* offset */
            invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getOffset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         4: .line 469
            ldc ", offsetTimestamp="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 3 /* offset */
            invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getTimestamp:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         5: .line 466
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         6: .line 465
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         7: .line 470
            return
        end local 3 // io.vertx.kafka.client.consumer.OffsetAndTimestamp offset
        end local 2 // io.vertx.kafka.client.common.TopicPartition topic
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     2   topic  Lio/vertx/kafka/client/common/TopicPartition;
            0    8     3  offset  Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;

  private static void lambda$39(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 506
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Paused"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$40(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, java.lang.Void);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=5, locals=4, args_size=4
        start local 3 // java.lang.Void v
         0: .line 507
            aload 0
            ldc 5000
            aload 1
            aload 2
            invokedynamic handle(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;)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
                  examples/VertxKafkaClientExamples.lambda$41(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
         1: .line 510
            return
        end local 3 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     3     v  Ljava/lang/Void;

  private static void lambda$21(io.vertx.kafka.client.consumer.KafkaConsumerRecords);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecords;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecords records
         0: .line 304
            iconst_0
            istore 1 /* i */
        start local 1 // int i
         1: goto 7
         2: .line 305
      StackMap locals: int
      StackMap stack:
            aload 0 /* records */
            iload 1 /* i */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecords.recordAt:(I)Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;
            astore 2 /* record */
        start local 2 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         3: .line 306
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "key="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ",value="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.String
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         4: .line 307
            ldc ",partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            ldc ",offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         5: .line 306
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         6: .line 304
            iinc 1 /* i */ 1
      StackMap locals:
      StackMap stack:
         7: iload 1 /* i */
            aload 0 /* records */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecords.size:()I
            if_icmplt 2
        end local 1 // int i
         8: .line 309
            return
        end local 0 // io.vertx.kafka.client.consumer.KafkaConsumerRecords records
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    9     0  records  Lio/vertx/kafka/client/consumer/KafkaConsumerRecords<Ljava/lang/String;Ljava/lang/String;>;
            1    8     1        i  I
            3    6     2   record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$22(io.vertx.core.Vertx, java.lang.Long, java.lang.Throwable);
    descriptor: (Lio/vertx/core/Vertx;Ljava/lang/Long;Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 2 // java.lang.Throwable cause
         0: .line 311
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Something went wrong when polling "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* cause */
            invokevirtual java.lang.Throwable.toString:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 312
            aload 2 /* cause */
            invokevirtual java.lang.Throwable.printStackTrace:()V
         2: .line 315
            aload 0
            aload 1
            invokevirtual java.lang.Long.longValue:()J
            invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
            pop
         3: .line 316
            return
        end local 2 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     2  cause  Ljava/lang/Throwable;

  private static void lambda$41(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // java.lang.Long timeId
         0: .line 509
            aload 0
            aload 1
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.resume:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
            return
        end local 2 // java.lang.Long timeId
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     2  timeId  Ljava/lang/Long;
}
SourceFile: "VertxKafkaClientExamples.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
    RuntimeInvisibleAnnotations: 
      io.vertx.docgen.Source()