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 58
            aload 1 /* adminClient */
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.listTopics:()Lio/vertx/core/Future;
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/KafkaAdminClientExamples.lambda$0(Ljava/util/Set;)V (6)
                  (Ljava/util/Set;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 61
            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=2, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 68
            aload 1 /* adminClient */
            ldc "my-topic"
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.describeTopics:(Ljava/util/List;)Lio/vertx/core/Future;
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/KafkaAdminClientExamples.lambda$1(Ljava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 82
            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=2, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 89
            aload 1 /* adminClient */
            ldc "topicToDelete"
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.deleteTopics:(Ljava/util/List;)Lio/vertx/core/Future;
         1: .line 90
            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(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         2: .line 93
            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(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 96
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lexamples/KafkaAdminClientExamples;
            0    4     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;
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.createTopics:(Ljava/util/List;)Lio/vertx/core/Future;
         1: .line 104
            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(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         2: .line 107
            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(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         3: .line 110
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0         this  Lexamples/KafkaAdminClientExamples;
            0    4     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 118
            aload 1 /* adminClient */
         1: .line 119
            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 118
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.describeConfigs:(Ljava/util/List;)Lio/vertx/core/Future;
         3: .line 119
            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(Ljava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         4: .line 122
            return
        end local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
        end local 0 // examples.KafkaAdminClientExamples this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    5     0         this  Lexamples/KafkaAdminClientExamples;
            0    5     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 129
            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 131
            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 132
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 4 /* updateConfig */
        start local 4 // java.util.Map updateConfig
         3: .line 133
            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 134
            aload 1 /* adminClient */
            aload 4 /* updateConfig */
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.alterConfigs:(Ljava/util/Map;)Lio/vertx/core/Future;
         5: .line 135
            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(Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
         6: .line 138
            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$8(Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         7: .line 141
            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    8     0            this  Lexamples/KafkaAdminClientExamples;
            0    8     1     adminClient  Lio/vertx/kafka/admin/KafkaAdminClient;
            1    8     2        resource  Lio/vertx/kafka/client/common/ConfigResource;
            2    8     3  retentionEntry  Lio/vertx/kafka/admin/ConfigEntry;
            3    8     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 148
            aload 1 /* adminClient */
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.listConsumerGroups:()Lio/vertx/core/Future;
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/KafkaAdminClientExamples.lambda$9(Ljava/util/List;)V (6)
                  (Ljava/util/List;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 151
            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=2, locals=2, args_size=2
        start local 0 // examples.KafkaAdminClientExamples this
        start local 1 // io.vertx.kafka.admin.KafkaAdminClient adminClient
         0: .line 158
            aload 1 /* adminClient */
            ldc "my-group"
            invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
            invokeinterface io.vertx.kafka.admin.KafkaAdminClient.describeConsumerGroups:(Ljava/util/List;)Lio/vertx/core/Future;
            invokedynamic handle()Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/KafkaAdminClientExamples.lambda$10(Ljava/util/Map;)V (6)
                  (Ljava/util/Map;)V
            invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 170
            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(java.util.Set);
    descriptor: (Ljava/util/Set;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.util.Set topics
         0: .line 59
            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 /* topics */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.util.Set topics
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  topics  Ljava/util/Set<Ljava/lang/String;>;

  private static void lambda$1(java.util.Map);
    descriptor: (Ljava/util/Map;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // java.util.Map topics
         0: .line 69
            aload 0 /* topics */
            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 71
            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 72
            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 73
            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 71
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 75
            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: java.util.Map 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 76
            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 77
            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 78
            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 79
            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 76
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.vertx.kafka.client.common.TopicPartitionInfo topicPartitionInfo
        12: .line 75
      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 81
            return
        end local 0 // java.util.Map topics
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   14     0              topics  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(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 92
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$3(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 95
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$4(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 106
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$5(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 109
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

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

  private static void lambda$7(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Void v
         0: .line 137
            return
        end local 0 // java.lang.Void v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Void;

  private static void lambda$8(java.lang.Throwable);
    descriptor: (Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.lang.Throwable cause
         0: .line 140
            return
        end local 0 // java.lang.Throwable cause
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  cause  Ljava/lang/Throwable;

  private static void lambda$9(java.util.List);
    descriptor: (Ljava/util/List;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.util.List consumerGroups
         0: .line 149
            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 /* consumerGroups */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
            return
        end local 0 // java.util.List consumerGroups
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    1     0  consumerGroups  Ljava/util/List<Lio/vertx/kafka/admin/ConsumerGroupListing;>;

  private static void lambda$10(java.util.Map);
    descriptor: (Ljava/util/Map;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // java.util.Map consumerGroups
         0: .line 159
            aload 0 /* consumerGroups */
            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 161
            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 162
            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 163
            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 161
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
         5: .line 165
            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: java.util.Map 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 166
            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 167
            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 166
            invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
        end local 2 // io.vertx.kafka.admin.MemberDescription memberDescription
        10: .line 165
      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 169
            return
        end local 0 // java.util.Map consumerGroups
      LocalVariableTable:
        Start  End  Slot                      Name  Signature
            0   12     0            consumerGroups  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()