http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-kafka-client: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class 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 47
            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 75
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 76
            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 77
            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 78
            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 79
            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 80
            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 81
            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 84
            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 85
            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 90
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 91
            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 92
            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 93
            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 94
            aload 2 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 97
            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 98
            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 107
            new java.util.Properties
            dup
            invokespecial java.util.Properties.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Properties config
         1: .line 108
            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 109
            aload 2 /* config */
            ldc "acks"
            ldc "1"
            invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 112
            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 113
            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 118
            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 124
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topics */
        start local 2 // java.util.Set topics
         2: .line 125
            aload 2 /* topics */
            ldc "topic1"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 126
            aload 2 /* topics */
            ldc "topic2"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         4: .line 127
            aload 2 /* topics */
            ldc "topic3"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         5: .line 128
            aload 1 /* consumer */
            aload 2 /* topics */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         6: .line 131
            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 132
            aload 1 /* consumer */
            aload 3 /* pattern */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/regex/Pattern;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         8: .line 135
            aload 1 /* consumer */
            ldc "a-single-topic"
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         9: .line 136
            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=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 141
            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 147
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topics */
        start local 2 // java.util.Set topics
         2: .line 148
            aload 2 /* topics */
            ldc "topic1"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 149
            aload 2 /* topics */
            ldc "topic2"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         4: .line 150
            aload 2 /* topics */
            ldc "topic3"
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         5: .line 151
            aload 1 /* consumer */
            aload 2 /* topics */
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         6: .line 160
            aload 1 /* consumer */
            ldc "a-single-topic"
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         7: .line 167
            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    8     0      this  Lexamples/VertxKafkaClientExamples;
            0    8     1  consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            2    8     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=3, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .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$4(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 183
            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$5(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 191
            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(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 200
            aload 1 /* consumer */
            ldc "test"
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         4: .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    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 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 213
            aload 1 /* consumer */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe:()Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 214
            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 226
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 232
            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 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 242
            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$9(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 248
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topicPartitions */
        start local 2 // java.util.Set topicPartitions
         2: .line 249
            aload 2 /* topicPartitions */
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         3: .line 250
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         4: .line 251
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         5: .line 249
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         6: .line 254
            aload 1 /* consumer */
            aload 2 /* topicPartitions */
            aload 1 /* consumer */
            invokedynamic handle(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$10(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.assign:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         7: .line 271
            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    8     0             this  Lexamples/VertxKafkaClientExamples;
            0    8     1         consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            2    8     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=3, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 282
            aload 1 /* consumer */
            ldc "test"
            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/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsFor:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 291
            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 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 296
            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$13(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.listTopics:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 307
            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 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=4, 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 320
            aload 2 /* consumer */
            ldc "test"
            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$15(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 343
            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    2     0      this  Lexamples/VertxKafkaClientExamples;
            0    2     1     vertx  Lio/vertx/core/Vertx;
            0    2     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=3, locals=2, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
         0: .line 348
            aload 1 /* producer */
            ldc "test"
            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$18(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.partitionsFor:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
         1: .line 357
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lexamples/VertxKafkaClientExamples;
            0    2     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 369
            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$19(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.commit:(Lio/vertx/core/Handler;)V
         1: .line 375
            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=5, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 379
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 380
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 381
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 379
            astore 2 /* topicPartition */
        start local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 384
            aload 1 /* consumer */
            aload 2 /* topicPartition */
            ldc 10
            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$20(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seek:(Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         5: .line 391
            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    6     0            this  Lexamples/VertxKafkaClientExamples;
            0    6     1        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    6     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=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 395
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 396
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 397
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 395
            astore 2 /* topicPartition */
        start local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 400
            aload 1 /* consumer */
            aload 2 /* topicPartition */
            invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
            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/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seekToBeginning:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         5: .line 406
            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    6     0            this  Lexamples/VertxKafkaClientExamples;
            0    6     1        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    6     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=3, locals=3, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 415
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 416
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 417
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 415
            astore 2 /* topicPartition */
        start local 2 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 420
            aload 1 /* consumer */
            aload 2 /* topicPartition */
            invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
            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$22(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seekToEnd:(Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         5: .line 426
            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    6     0            this  Lexamples/VertxKafkaClientExamples;
            0    6     1        consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            4    6     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=3, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 435
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topicPartitions */
        start local 2 // java.util.Set topicPartitions
         1: .line 436
            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 437
            aload 2 /* topicPartitions */
            aload 3 /* topicPartition */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 439
            aload 1 /* consumer */
            aload 2 /* topicPartitions */
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets:(Ljava/util/Set;Lio/vertx/core/Handler;)V
         4: .line 449
            aload 1 /* consumer */
            aload 3 /* topicPartition */
            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$25(Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets:(Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)V
         5: .line 457
            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    6     0             this  Lexamples/VertxKafkaClientExamples;
            0    6     1         consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            1    6     2  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            2    6     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=3, locals=4, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 465
            new java.util.HashSet
            dup
            invokespecial java.util.HashSet.<init>:()V
            astore 2 /* topicPartitions */
        start local 2 // java.util.Set topicPartitions
         1: .line 466
            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 467
            aload 2 /* topicPartitions */
            aload 3 /* topicPartition */
            invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
            pop
         3: .line 469
            aload 1 /* consumer */
            aload 2 /* topicPartitions */
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets:(Ljava/util/Set;Lio/vertx/core/Handler;)V
         4: .line 479
            aload 1 /* consumer */
            aload 3 /* topicPartition */
            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$28(Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets:(Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)V
         5: .line 486
            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    6     0             this  Lexamples/VertxKafkaClientExamples;
            0    6     1         consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            1    6     2  topicPartitions  Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
            2    6     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=6, locals=6, args_size=2
        start local 0 // examples.VertxKafkaClientExamples this
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumer consumer
         0: .line 495
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* topicPartitionsWithTimestamps */
        start local 2 // java.util.Map topicPartitionsWithTimestamps
         1: .line 496
            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 499
            invokestatic java.lang.System.currentTimeMillis:()J
            ldc 60000
            lsub
            lstore 4 /* timestamp */
        start local 4 // long timestamp
         3: .line 501
            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 502
            aload 1 /* consumer */
            aload 2 /* topicPartitionsWithTimestamps */
            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$29(JLio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes:(Ljava/util/Map;Lio/vertx/core/Handler;)V
         5: .line 515
            aload 1 /* consumer */
            aload 3 /* topicPartition */
            lload 4 /* timestamp */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            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$31(Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes:(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;Lio/vertx/core/Handler;)V
         6: .line 525
            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    7     0                           this  Lexamples/VertxKafkaClientExamples;
            0    7     1                       consumer  Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
            1    7     2  topicPartitionsWithTimestamps  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;
            2    7     3                 topicPartition  Lio/vertx/kafka/client/common/TopicPartition;
            3    7     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 535
            new io.vertx.kafka.client.common.TopicPartition
            dup
            invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
         1: .line 536
            ldc "test"
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
         2: .line 537
            iconst_0
            invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
         3: .line 535
            astore 3 /* topicPartition */
        start local 3 // io.vertx.kafka.client.common.TopicPartition topicPartition
         4: .line 540
            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$32(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 564
            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 568
            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$35(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.close:(Lio/vertx/core/Handler;)V
         1: .line 575
            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 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 579
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 6
         2: .line 583
      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 582
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         4: .line 585
            aload 1 /* producer */
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
        end local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 579
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            iconst_5
            if_icmplt 2
        end local 2 // int i
         7: .line 587
            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 596
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 6
         2: .line 600
      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 599
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         4: .line 602
            aload 1 /* producer */
            aload 3 /* record */
            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$36(Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.send:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
        end local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 596
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            iconst_5
            if_icmplt 2
        end local 2 // int i
         7: .line 615
            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 624
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 6
         2: .line 628
      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 627
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         4: .line 630
            aload 1 /* producer */
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
        end local 3 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 624
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         6: iload 2 /* i */
            bipush 10
            if_icmplt 2
        end local 2 // int i
         7: .line 632
            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 642
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         1: goto 7
         2: .line 645
      StackMap locals: int
      StackMap stack:
            iload 2 /* i */
            iconst_2
            irem
            istore 3 /* key */
        start local 3 // int key
         3: .line 649
            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 648
            astore 4 /* record */
        start local 4 // io.vertx.kafka.client.producer.KafkaProducerRecord record
         5: .line 651
            aload 1 /* producer */
            aload 4 /* record */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/kafka/client/producer/KafkaProducer;
            pop
        end local 4 // io.vertx.kafka.client.producer.KafkaProducerRecord record
        end local 3 // int key
         6: .line 642
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         7: iload 2 /* i */
            bipush 10
            if_icmplt 2
        end local 2 // int i
         8: .line 653
            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 658
            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 661
            aload 3 /* producer1 */
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.close:()V
         2: .line 662
            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 665
            aload 1 /* producer */
            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$37(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.producer.KafkaProducer.close:(Lio/vertx/core/Handler;)V
         1: .line 672
            return
        end local 1 // io.vertx.kafka.client.producer.KafkaProducer producer
        end local 0 // examples.VertxKafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lexamples/VertxKafkaClientExamples;
            0    2     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 683
            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$38(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 686
            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 691
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        start local 1 // java.util.Map config
         1: .line 692
            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 693
            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 694
            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 695
            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 696
            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 697
            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 700
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
         8: .line 701
            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 702
            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 703
            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 704
            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 705
            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 706
            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 709
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        15: .line 710
            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 711
            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 712
            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 713
            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 714
            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 715
            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 716
            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 721
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        start local 1 // java.util.Map config
         1: .line 722
            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 723
            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 724
            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 725
            aload 1 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         5: .line 728
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
         6: .line 729
            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 730
            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 731
            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 732
            aload 1 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        10: .line 735
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* config */
        11: .line 736
            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 737
            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 738
            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 739
            aload 1 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        15: .line 740
            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 744
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 745
            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 746
            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 747
            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 748
            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 751
            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 754
            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 757
            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 758
            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 762
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 763
            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 764
            aload 2 /* config */
            ldc "acks"
            ldc "1"
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 767
            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 770
            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 773
            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 774
            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 119
            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 120
            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 119
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 121
            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 142
            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 143
            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 142
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 144
            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(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 152
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 153
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 154
            goto 4
         3: .line 155
      StackMap locals:
      StackMap stack:
            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 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            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
         4: .line 157
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$3(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 161
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 162
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 163
            goto 4
         3: .line 164
      StackMap locals:
      StackMap stack:
            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 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            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
         4: .line 166
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$4(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 178
            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 179
            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 178
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 180
            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$5(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 assigned"
            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$6(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 193
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Partitions revoked"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         1: .line 194
            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 195
            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 194
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 197
            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$7(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 202
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 203
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 205
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$8(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 228
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 229
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer unsubscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 231
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$9(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 243
            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 244
            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 243
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 245
            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$10(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult done
         0: .line 256
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 257
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Partition assigned"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 260
            aload 0
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.assignment:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         3: .line 270
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     1  done  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$12(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 284
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 286
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.List
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 2
            goto 4
      StackMap locals: io.vertx.core.AsyncResult top java.util.Iterator
      StackMap stack:
         2: 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
         3: .line 287
            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
         4: .line 286
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 290
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    6     0             ar  Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;
            3    4     1  partitionInfo  Lio/vertx/kafka/client/common/PartitionInfo;

  private static void lambda$13(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 298
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 300
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Map
            astore 1 /* map */
        start local 1 // java.util.Map map
         2: .line 301
            aload 1 /* map */
            aload 1 /* map */
            invokedynamic accept(Ljava/util/Map;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  examples/VertxKafkaClientExamples.lambda$14(Ljava/util/Map;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
        end local 1 // java.util.Map map
         3: .line 306
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0    ar  Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;>;
            2    3     1   map  Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;

  private static void lambda$15(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 322
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 323
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer subscribed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 325
            aload 0
            ldc 1000
            aload 1
            invokedynamic handle(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$16(Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Long;)V (6)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
            pop2
         3: .line 342
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     2    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$18(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 350
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 352
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.List
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 2
            goto 4
      StackMap locals: io.vertx.core.AsyncResult top java.util.Iterator
      StackMap stack:
         2: 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
         3: .line 353
            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
         4: .line 352
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 356
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    6     0             ar  Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;
            3    4     1  partitionInfo  Lio/vertx/kafka/client/common/PartitionInfo;

  private static void lambda$19(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 371
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 372
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Last read message offset committed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 374
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$20(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult done
         0: .line 386
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 387
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Seeking done"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 389
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  done  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$21(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult done
         0: .line 402
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 403
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Seeking done"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 405
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  done  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$22(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult done
         0: .line 422
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 2
         1: .line 423
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Seeking done"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 425
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  done  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$23(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult done
         0: .line 440
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 441
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Map
            astore 1 /* results */
        start local 1 // java.util.Map results
         2: .line 442
            aload 1 /* 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$24(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
        end local 1 // java.util.Map results
         3: .line 446
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     done  Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;>;
            2    3     1  results  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;

  private static void lambda$25(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=2
        start local 1 // io.vertx.core.AsyncResult done
         0: .line 450
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 451
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.lang.Long
            astore 2 /* beginningOffset */
        start local 2 // java.lang.Long beginningOffset
         2: .line 452
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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;
         3: .line 453
            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 2 /* beginningOffset */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 452
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // java.lang.Long beginningOffset
         5: .line 455
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    6     1             done  Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;
            2    5     2  beginningOffset  Ljava/lang/Long;

  private static void lambda$26(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.core.AsyncResult done
         0: .line 470
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 471
            aload 0 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Map
            astore 1 /* results */
        start local 1 // java.util.Map results
         2: .line 472
            aload 1 /* 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$27(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
        end local 1 // java.util.Map results
         3: .line 476
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     done  Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;>;
            2    3     1  results  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;

  private static void lambda$28(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=2
        start local 1 // io.vertx.core.AsyncResult done
         0: .line 480
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 481
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.lang.Long
            astore 2 /* endOffset */
        start local 2 // java.lang.Long endOffset
         2: .line 482
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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;
         3: .line 483
            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 2 /* endOffset */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 482
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // java.lang.Long endOffset
         5: .line 485
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    6     1       done  Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;
            2    5     2  endOffset  Ljava/lang/Long;

  private static void lambda$29(long, io.vertx.core.AsyncResult);
    descriptor: (JLio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=2
        start local 2 // io.vertx.core.AsyncResult done
         0: .line 503
            aload 2 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 504
            aload 2 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Map
            astore 3 /* results */
        start local 3 // java.util.Map results
         2: .line 505
            aload 3 /* 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$30(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
        end local 3 // java.util.Map results
         3: .line 512
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     2     done  Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;>;
            2    3     3  results  Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;

  private static void lambda$31(io.vertx.kafka.client.common.TopicPartition, long, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=5, args_size=3
        start local 3 // io.vertx.core.AsyncResult done
         0: .line 516
            aload 3 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 7
         1: .line 517
            aload 3 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.consumer.OffsetAndTimestamp
            astore 4 /* offsetAndTimestamp */
        start local 4 // io.vertx.kafka.client.consumer.OffsetAndTimestamp offsetAndTimestamp
         2: .line 518
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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;
         3: .line 519
            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;
         4: .line 520
            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 4 /* offsetAndTimestamp */
            invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getOffset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
         5: .line 521
            ldc ", offsetTimestamp="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 4 /* offsetAndTimestamp */
            invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getTimestamp:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         6: .line 518
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 4 // io.vertx.kafka.client.consumer.OffsetAndTimestamp offsetAndTimestamp
         7: .line 524
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    8     3                done  Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;
            2    7     4  offsetAndTimestamp  Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;

  private static void lambda$32(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=5, locals=4, args_size=4
        start local 3 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 541
            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 542
            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 541
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 545
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
            ifne 5
            aload 3 /* record */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
            ldc 5
            lcmp
            ifne 5
         4: .line 548
            aload 0
            aload 1
            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$33(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.pause:(Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         5: .line 563
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     3  record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$35(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 569
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 570
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Consumer is now closed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 571
            goto 4
         3: .line 572
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "close failed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 574
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0   res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$36(io.vertx.kafka.client.producer.KafkaProducerRecord, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=2
        start local 1 // io.vertx.core.AsyncResult done
         0: .line 604
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 6
         1: .line 606
            aload 1 /* done */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.producer.RecordMetadata
            astore 2 /* recordMetadata */
        start local 2 // io.vertx.kafka.client.producer.RecordMetadata recordMetadata
         2: .line 607
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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 2 /* recordMetadata */
            invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getTopic:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         3: .line 608
            ldc ", partition="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* recordMetadata */
            invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
         4: .line 609
            ldc ", offset="
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* recordMetadata */
            invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getOffset:()J
            invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         5: .line 607
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.vertx.kafka.client.producer.RecordMetadata recordMetadata
         6: .line 612
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult done
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    7     1            done  Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/producer/RecordMetadata;>;
            2    6     2  recordMetadata  Lio/vertx/kafka/client/producer/RecordMetadata;

  private static void lambda$37(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult res
         0: .line 666
            aload 0 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 667
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Producer is now closed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 668
            goto 4
         3: .line 669
      StackMap locals:
      StackMap stack:
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "close failed"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         4: .line 671
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0   res  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$38(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 684
            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 685
            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$11(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // io.vertx.core.AsyncResult done1
         0: .line 262
            aload 0 /* done1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 5
         1: .line 264
            aload 0 /* done1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Set
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 2
            goto 4
      StackMap locals: io.vertx.core.AsyncResult 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 265
            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 264
      StackMap locals:
      StackMap stack:
            aload 2
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         5: .line 268
      StackMap locals: io.vertx.core.AsyncResult
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult done1
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    6     0           done1  Lio/vertx/core/AsyncResult<Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;>;
            3    4     1  topicPartition  Lio/vertx/kafka/client/common/TopicPartition;

  private static void lambda$14(java.util.Map, java.lang.String, java.util.List);
    descriptor: (Ljava/util/Map;Ljava/lang/String;Ljava/util/List;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 1 // java.lang.String topic
        start local 2 // java.util.List partitions
         0: .line 302
            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 1 /* 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 303
            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 0
            aload 1 /* topic */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            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 304
            return
        end local 2 // java.util.List partitions
        end local 1 // java.lang.String topic
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    3     1       topic  Ljava/lang/String;
            0    3     2  partitions  Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;

  private static void lambda$16(io.vertx.kafka.client.consumer.KafkaConsumer, java.lang.Long);
    descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;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 timerId
         0: .line 327
            aload 0
            ldc 100
            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(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.poll:(JLio/vertx/core/Handler;)V
         1: .line 340
            return
        end local 1 // java.lang.Long timerId
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     1  timerId  Ljava/lang/Long;

  private static void lambda$24(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 443
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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;
         1: .line 444
            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;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 443
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 444
            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    4     0            topic  Lio/vertx/kafka/client/common/TopicPartition;
            0    4     1  beginningOffset  Ljava/lang/Long;

  private static void lambda$27(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 endOffset
         0: .line 473
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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;
         1: .line 474
            aload 0 /* topic */
            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;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         2: .line 473
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         3: .line 474
            return
        end local 1 // java.lang.Long endOffset
        end local 0 // io.vertx.kafka.client.common.TopicPartition topic
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0      topic  Lio/vertx/kafka/client/common/TopicPartition;
            0    4     1  endOffset  Ljava/lang/Long;

  private static void lambda$30(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 506
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            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;
         1: .line 507
            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;
         2: .line 508
            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;
         3: .line 509
            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;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 506
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 509
            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    6     2   topic  Lio/vertx/kafka/client/common/TopicPartition;
            0    6     3  offset  Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;

  private static void lambda$33(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=5, locals=4, args_size=4
        start local 3 // io.vertx.core.AsyncResult ar
         0: .line 550
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 552
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            ldc "Paused"
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         2: .line 555
            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$34(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
            pop2
         3: .line 561
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     3    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$17(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar1
         0: .line 329
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 10
         1: .line 331
            aload 0 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.consumer.KafkaConsumerRecords
            astore 1 /* records */
        start local 1 // io.vertx.kafka.client.consumer.KafkaConsumerRecords records
         2: .line 332
            iconst_0
            istore 2 /* i */
        start local 2 // int i
         3: goto 9
         4: .line 333
      StackMap locals: io.vertx.kafka.client.consumer.KafkaConsumerRecords int
      StackMap stack:
            aload 1 /* records */
            iload 2 /* i */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecords.recordAt:(I)Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;
            astore 3 /* record */
        start local 3 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         5: .line 334
            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;
         6: .line 335
            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;
         7: .line 334
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 3 // io.vertx.kafka.client.consumer.KafkaConsumerRecord record
         8: .line 332
            iinc 2 /* i */ 1
      StackMap locals:
      StackMap stack:
         9: iload 2 /* i */
            aload 1 /* records */
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecords.size:()I
            if_icmplt 4
        end local 2 // int i
        end local 1 // io.vertx.kafka.client.consumer.KafkaConsumerRecords records
        10: .line 338
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.vertx.core.AsyncResult ar1
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   11     0      ar1  Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/consumer/KafkaConsumerRecords<Ljava/lang/String;Ljava/lang/String;>;>;
            2   10     1  records  Lio/vertx/kafka/client/consumer/KafkaConsumerRecords<Ljava/lang/String;Ljava/lang/String;>;
            3   10     2        i  I
            5    8     3   record  Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;

  private static void lambda$34(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 558
            aload 0
            aload 1
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.resume:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            pop
         1: .line 559
            return
        end local 2 // java.lang.Long timeId
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     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()