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.KafkaAdminClientExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.KafkaAdminClientExamples
  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.KafkaAdminClientExamples this
         0: .line 39
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/KafkaAdminClientExamples;

  public void exampleCreateAdminClient(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.KafkaAdminClientExamples this
        start local 1 // io.vertx.core.Vertx vertx
         0: .line 47
            new java.util.Properties
            dup
            invokespecial java.util.Properties.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Properties config
         1: .line 48
            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 50
            aload 1 /* vertx */
            aload 2 /* config */
            invokestatic io.vertx.kafka.admin.KafkaAdminClient.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/admin/KafkaAdminClient;
            pop
         3: .line 51
            return
        end local 2 // java.util.Properties config
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lexamples/KafkaAdminClientExamples;
            0    4     1   vertx  Lio/vertx/core/Vertx;
            1    4     2  config  Ljava/util/Properties;
    MethodParameters:
       Name  Flags
      vertx  

  public void exampleListTopics(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 59
            aload 1 /* adminClient */
            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/KafkaAdminClientExamples.lambda$0(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.listTopics:(Lio/vertx/core/Handler;)V
         1: .line 62
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lexamples/KafkaAdminClientExamples;
            0    2     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleDescribeTopics(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 70
            aload 1 /* adminClient */
            ldc "my-topic"
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            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/KafkaAdminClientExamples.lambda$1(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.describeTopics:(Ljava/util/List;Lio/vertx/core/Handler;)V
         1: .line 84
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lexamples/KafkaAdminClientExamples;
            0    2     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleDeleteTopics(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 92
            aload 1 /* adminClient */
            ldc "topicToDelete"
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            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/KafkaAdminClientExamples.lambda$2(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.deleteTopics:(Ljava/util/List;Lio/vertx/core/Handler;)V
         1: .line 95
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lexamples/KafkaAdminClientExamples;
            0    2     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleCreateTopics(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 103
            aload 1 /* adminClient */
            new io.vertx.kafka.admin.NewTopic
            dup
            ldc "testCreateTopic"
            iconst_1
            iconst_1
            invokespecial io.vertx.kafka.admin.NewTopic.<init>:(Ljava/lang/String;IS)V
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            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/KafkaAdminClientExamples.lambda$3(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.createTopics:(Ljava/util/List;Lio/vertx/core/Handler;)V
         1: .line 106
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lexamples/KafkaAdminClientExamples;
            0    2     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleDescribeConfigs(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 115
            aload 1 /* adminClient */
         1: .line 116
            new io.vertx.kafka.client.common.ConfigResource
            dup
            getstatic org.apache.kafka.common.config.ConfigResource$Type.TOPIC:Lorg/apache/kafka/common/config/ConfigResource$Type;
            ldc "my-topic"
            invokespecial io.vertx.kafka.client.common.ConfigResource.<init>:(Lorg/apache/kafka/common/config/ConfigResource$Type;Ljava/lang/String;)V
         2: .line 115
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
         3: .line 116
            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/KafkaAdminClientExamples.lambda$4(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
         4: .line 115
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.describeConfigs:(Ljava/util/List;Lio/vertx/core/Handler;)V
         5: .line 119
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    6     0         this  Lexamples/KafkaAdminClientExamples;
            0    6     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleAlterConfigs(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 127
            new io.vertx.kafka.client.common.ConfigResource
            dup
            getstatic org.apache.kafka.common.config.ConfigResource$Type.TOPIC:Lorg/apache/kafka/common/config/ConfigResource$Type;
            ldc "my-topic"
            invokespecial io.vertx.kafka.client.common.ConfigResource.<init>:(Lorg/apache/kafka/common/config/ConfigResource$Type;Ljava/lang/String;)V
            astore 2 /* resource */
        start local 2 // io.vertx.kafka.client.common.ConfigResource resource
         1: .line 129
            new io.vertx.kafka.admin.ConfigEntry
            dup
            ldc "retention.ms"
            ldc "51000"
            invokespecial io.vertx.kafka.admin.ConfigEntry.<init>:(Ljava/lang/String;Ljava/lang/String;)V
            astore 3 /* retentionEntry */
        start local 3 // io.vertx.kafka.admin.ConfigEntry retentionEntry
         2: .line 130
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 4 /* updateConfig */
        start local 4 // java.util.Map updateConfig
         3: .line 131
            aload 4 /* updateConfig */
            aload 2 /* resource */
            new io.vertx.kafka.admin.Config
            dup
            aload 3 /* retentionEntry */
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            invokespecial io.vertx.kafka.admin.Config.<init>:(Ljava/util/List;)V
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         4: .line 133
            aload 1 /* adminClient */
            aload 4 /* updateConfig */
            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/KafkaAdminClientExamples.lambda$5(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.alterConfigs:(Ljava/util/Map;Lio/vertx/core/Handler;)V
         5: .line 136
            return
        end local 4 // java.util.Map updateConfig
        end local 3 // io.vertx.kafka.admin.ConfigEntry retentionEntry
        end local 2 // io.vertx.kafka.client.common.ConfigResource resource
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    6     0            this  Lexamples/KafkaAdminClientExamples;
            0    6     1     adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
            1    6     2        resource  Lio/vertx/kafka/client/common/ConfigResource;
            2    6     3  retentionEntry  Lio/vertx/kafka/admin/ConfigEntry;
            3    6     4    updateConfig  Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleListConsumerGroups(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 144
            aload 1 /* adminClient */
            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/KafkaAdminClientExamples.lambda$6(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.listConsumerGroups:(Lio/vertx/core/Handler;)V
         1: .line 147
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lexamples/KafkaAdminClientExamples;
            0    2     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  public void exampleDescribeConsumerGroups(io.vertx.kafka.admin.KafkaAdminClient);
    descriptor: (Lio/vertx/kafka/admin/KafkaAdminClient;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 155
            aload 1 /* adminClient */
            ldc "my-group"
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            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/KafkaAdminClientExamples.lambda$7(Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.describeConsumerGroups:(Ljava/util/List;Lio/vertx/core/Handler;)V
         1: .line 167
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lexamples/KafkaAdminClientExamples;
            0    2     1  adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
    MethodParameters:
             Name  Flags
      adminClient  

  private static void lambda$0(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 60
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Topics= "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()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
         1: .line 61
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0    ar  Lio/vertx/core/AsyncResult<Ljava/util/Set<Ljava/lang/String;>;>;

  private static void lambda$1(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 ar
         0: .line 71
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Map
            ldc "first-topic"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.kafka.admin.TopicDescription
            astore 1 /* topicDescription */
        start local 1 // io.vertx.kafka.admin.TopicDescription topicDescription
         1: .line 73
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Topic name="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* topicDescription */
            invokevirtual io.vertx.kafka.admin.TopicDescription.getName:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 74
            ldc " isInternal= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* topicDescription */
            invokevirtual io.vertx.kafka.admin.TopicDescription.isInternal:()Z
            invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
         3: .line 75
            ldc " partitions= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* topicDescription */
            invokevirtual io.vertx.kafka.admin.TopicDescription.getPartitions:()Ljava/util/List;
            invokeinterface java.util.List.size:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 73
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 77
            aload 1 /* topicDescription */
            invokevirtual io.vertx.kafka.admin.TopicDescription.getPartitions:()Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 12
      StackMap locals: io.vertx.core.AsyncResult io.vertx.kafka.admin.TopicDescription top java.util.Iterator
      StackMap stack:
         6: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.kafka.client.common.TopicPartitionInfo
            astore 2 /* topicPartitionInfo */
        start local 2 // io.vertx.kafka.client.common.TopicPartitionInfo topicPartitionInfo
         7: .line 78
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Partition id= "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* topicPartitionInfo */
            invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.getPartition:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
         8: .line 79
            ldc " leaderId= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* topicPartitionInfo */
            invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.getLeader:()Lio/vertx/kafka/client/common/Node;
            invokevirtual io.vertx.kafka.client.common.Node.getId:()I
            invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
         9: .line 80
            ldc " replicas= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* topicPartitionInfo */
            invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.getReplicas:()Ljava/util/List;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
        10: .line 81
            ldc " isr= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* topicPartitionInfo */
            invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.getIsr:()Ljava/util/List;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        11: .line 78
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.vertx.kafka.client.common.TopicPartitionInfo topicPartitionInfo
        12: .line 77
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
        end local 1 // io.vertx.kafka.admin.TopicDescription topicDescription
        13: .line 83
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   14     0                  ar  Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/TopicDescription;>;>;
            1   13     1    topicDescription  Lio/vertx/kafka/admin/TopicDescription;
            7   12     2  topicPartitionInfo  Lio/vertx/kafka/client/common/TopicPartitionInfo;

  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=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 94
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     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=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 105
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$4(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 118
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;>;

  private static void lambda$5(io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 135
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$6(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 145
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "ConsumerGroups= "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()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
         1: .line 146
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0    ar  Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/admin/ConsumerGroupListing;>;>;

  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=4, locals=4, args_size=1
        start local 0 // io.vertx.core.AsyncResult ar
         0: .line 156
            aload 0 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast java.util.Map
            ldc "my-group"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.kafka.admin.ConsumerGroupDescription
            astore 1 /* consumerGroupDescription */
        start local 1 // io.vertx.kafka.admin.ConsumerGroupDescription consumerGroupDescription
         1: .line 158
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "Group id="
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* consumerGroupDescription */
            invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.getGroupId:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         2: .line 159
            ldc " state= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* consumerGroupDescription */
            invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.getState:()Lorg/apache/kafka/common/ConsumerGroupState;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
         3: .line 160
            ldc " coordinator host= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 1 /* consumerGroupDescription */
            invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.getCoordinator:()Lio/vertx/kafka/client/common/Node;
            invokevirtual io.vertx.kafka.client.common.Node.getHost:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         4: .line 158
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 162
            aload 1 /* consumerGroupDescription */
            invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.getMembers:()Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 10
      StackMap locals: io.vertx.core.AsyncResult io.vertx.kafka.admin.ConsumerGroupDescription top java.util.Iterator
      StackMap stack:
         6: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.kafka.admin.MemberDescription
            astore 2 /* memberDescription */
        start local 2 // io.vertx.kafka.admin.MemberDescription memberDescription
         7: .line 163
            getstatic java.lang.System.out:Ljava/io/PrintStream;
            new java.lang.StringBuilder
            dup
            ldc "client id= "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 2 /* memberDescription */
            invokevirtual io.vertx.kafka.admin.MemberDescription.getClientId:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
         8: .line 164
            ldc " topic partitions= "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 2 /* memberDescription */
            invokevirtual io.vertx.kafka.admin.MemberDescription.getAssignment:()Lio/vertx/kafka/admin/MemberAssignment;
            invokevirtual io.vertx.kafka.admin.MemberAssignment.getTopicPartitions:()Ljava/util/Set;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
         9: .line 163
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.vertx.kafka.admin.MemberDescription memberDescription
        10: .line 162
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
        end local 1 // io.vertx.kafka.admin.ConsumerGroupDescription consumerGroupDescription
        11: .line 166
            return
        end local 0 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0   12     0                        ar  Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/ConsumerGroupDescription;>;>;
            1   11     1  consumerGroupDescription  Lio/vertx/kafka/admin/ConsumerGroupDescription;
            7   10     2         memberDescription  Lio/vertx/kafka/admin/MemberDescription;
}
SourceFile: "KafkaAdminClientExamples.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public final Type = org.apache.kafka.common.config.ConfigResource$Type of org.apache.kafka.common.config.ConfigResource
    RuntimeInvisibleAnnotations: 
      io.vertx.docgen.Source()