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 interface io.vertx.kafka.client.consumer.KafkaConsumer<K, V> extends io.vertx.core.streams.ReadStream<io.vertx.kafka.client.consumer.KafkaConsumerRecord<K, V>>
  minor version: 0
  major version: 59
  flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
  this_class: io.vertx.kafka.client.consumer.KafkaConsumer
  super_class: java.lang.Object
{
  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, org.apache.kafka.clients.consumer.Consumer<K, V>);
    descriptor: (Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/consumer/Consumer;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // org.apache.kafka.clients.consumer.Consumer consumer
         0: .line 62
            aload 0 /* vertx */
            aload 1 /* consumer */
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/consumer/Consumer;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 2 /* stream */
        start local 2 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 63
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 2 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            areturn
        end local 2 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 1 // org.apache.kafka.clients.consumer.Consumer consumer
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0     vertx  Lio/vertx/core/Vertx;
            0    2     1  consumer  Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
            1    2     2    stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
          Name  Flags
      vertx     
      consumer  

  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Map config
         0: .line 74
            aload 0 /* vertx */
            new java.util.HashMap
            dup
            aload 1 /* config */
            invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 2 /* stream */
        start local 2 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 75
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 2 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.registerCloseHook:()Lio/vertx/kafka/client/consumer/impl/KafkaConsumerImpl;
            areturn
        end local 2 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 1 // java.util.Map config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0   vertx  Lio/vertx/core/Vertx;
            0    2     1  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            1    2     2  stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    MethodParameters:
        Name  Flags
      vertx   
      config  

  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.String>, java.lang.Class<K>, java.lang.Class<V>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=5, args_size=4
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Map config
        start local 2 // java.lang.Class keyType
        start local 3 // java.lang.Class valueType
         0: .line 89
            aload 0 /* vertx */
            new java.util.HashMap
            dup
            aload 1 /* config */
            invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
            aload 2 /* keyType */
            aload 3 /* valueType */
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 4 /* stream */
        start local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 90
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 4 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.registerCloseHook:()Lio/vertx/kafka/client/consumer/impl/KafkaConsumerImpl;
            areturn
        end local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 3 // java.lang.Class valueType
        end local 2 // java.lang.Class keyType
        end local 1 // java.util.Map config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0      vertx  Lio/vertx/core/Vertx;
            0    2     1     config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            0    2     2    keyType  Ljava/lang/Class<TK;>;
            0    2     3  valueType  Ljava/lang/Class<TV;>;
            1    2     4     stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    MethodParameters:
           Name  Flags
      vertx      
      config     
      keyType    
      valueType  

  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.String>, org.apache.kafka.common.serialization.Deserializer<K>, org.apache.kafka.common.serialization.Deserializer<V>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;Lorg/apache/kafka/common/serialization/Deserializer;Lorg/apache/kafka/common/serialization/Deserializer;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=5, args_size=4
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Map config
        start local 2 // org.apache.kafka.common.serialization.Deserializer keyDeserializer
        start local 3 // org.apache.kafka.common.serialization.Deserializer valueDeserializer
         0: .line 105
            aload 0 /* vertx */
            new java.util.HashMap
            dup
            aload 1 /* config */
            invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
            aload 2 /* keyDeserializer */
            aload 3 /* valueDeserializer */
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Lorg/apache/kafka/common/serialization/Deserializer;Lorg/apache/kafka/common/serialization/Deserializer;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 4 /* stream */
        start local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 106
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 4 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.registerCloseHook:()Lio/vertx/kafka/client/consumer/impl/KafkaConsumerImpl;
            areturn
        end local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 3 // org.apache.kafka.common.serialization.Deserializer valueDeserializer
        end local 2 // org.apache.kafka.common.serialization.Deserializer keyDeserializer
        end local 1 // java.util.Map config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0              vertx  Lio/vertx/core/Vertx;
            0    2     1             config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            0    2     2    keyDeserializer  Lorg/apache/kafka/common/serialization/Deserializer<TK;>;
            0    2     3  valueDeserializer  Lorg/apache/kafka/common/serialization/Deserializer<TV;>;
            1    2     4             stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lorg/apache/kafka/common/serialization/Deserializer<TK;>;Lorg/apache/kafka/common/serialization/Deserializer<TV;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                   Name  Flags
      vertx              
      config             
      keyDeserializer    
      valueDeserializer  

  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, java.util.Properties);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Properties config
         0: .line 118
            aload 0 /* vertx */
            aload 1 /* config */
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 2 /* stream */
        start local 2 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 119
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 2 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.registerCloseHook:()Lio/vertx/kafka/client/consumer/impl/KafkaConsumerImpl;
            areturn
        end local 2 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 1 // java.util.Properties config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0   vertx  Lio/vertx/core/Vertx;
            0    2     1  config  Ljava/util/Properties;
            1    2     2  stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
        Name  Flags
      vertx   
      config  

  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, java.util.Properties, java.lang.Class<K>, java.lang.Class<V>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=5, args_size=4
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Properties config
        start local 2 // java.lang.Class keyType
        start local 3 // java.lang.Class valueType
         0: .line 134
            aload 0 /* vertx */
            aload 1 /* config */
            aload 2 /* keyType */
            aload 3 /* valueType */
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 4 /* stream */
        start local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 135
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 4 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.registerCloseHook:()Lio/vertx/kafka/client/consumer/impl/KafkaConsumerImpl;
            areturn
        end local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 3 // java.lang.Class valueType
        end local 2 // java.lang.Class keyType
        end local 1 // java.util.Properties config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0      vertx  Lio/vertx/core/Vertx;
            0    2     1     config  Ljava/util/Properties;
            0    2     2    keyType  Ljava/lang/Class<TK;>;
            0    2     3  valueType  Ljava/lang/Class<TV;>;
            1    2     4     stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
           Name  Flags
      vertx      
      config     
      keyType    
      valueType  

  public static <K, V> io.vertx.kafka.client.consumer.KafkaConsumer<K, V> create(io.vertx.core.Vertx, java.util.Properties, org.apache.kafka.common.serialization.Deserializer<K>, org.apache.kafka.common.serialization.Deserializer<V>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Deserializer;Lorg/apache/kafka/common/serialization/Deserializer;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=5, args_size=4
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Properties config
        start local 2 // org.apache.kafka.common.serialization.Deserializer keyDeserializer
        start local 3 // org.apache.kafka.common.serialization.Deserializer valueDeserializer
         0: .line 150
            aload 0 /* vertx */
            aload 1 /* config */
            aload 2 /* keyDeserializer */
            aload 3 /* valueDeserializer */
            invokestatic io.vertx.kafka.client.consumer.KafkaReadStream.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Deserializer;Lorg/apache/kafka/common/serialization/Deserializer;)Lio/vertx/kafka/client/consumer/KafkaReadStream;
            astore 4 /* stream */
        start local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
         1: .line 151
            new io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl
            dup
            aload 4 /* stream */
            invokespecial io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.<init>:(Lio/vertx/kafka/client/consumer/KafkaReadStream;)V
            invokevirtual io.vertx.kafka.client.consumer.impl.KafkaConsumerImpl.registerCloseHook:()Lio/vertx/kafka/client/consumer/impl/KafkaConsumerImpl;
            areturn
        end local 4 // io.vertx.kafka.client.consumer.KafkaReadStream stream
        end local 3 // org.apache.kafka.common.serialization.Deserializer valueDeserializer
        end local 2 // org.apache.kafka.common.serialization.Deserializer keyDeserializer
        end local 1 // java.util.Properties config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0              vertx  Lio/vertx/core/Vertx;
            0    2     1             config  Ljava/util/Properties;
            0    2     2    keyDeserializer  Lorg/apache/kafka/common/serialization/Deserializer<TK;>;
            0    2     3  valueDeserializer  Lorg/apache/kafka/common/serialization/Deserializer<TV;>;
            1    2     4             stream  Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Deserializer<TK;>;Lorg/apache/kafka/common/serialization/Deserializer<TV;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                   Name  Flags
      vertx              
      config             
      keyDeserializer    
      valueDeserializer  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> handler(io.vertx.core.Handler<io.vertx.kafka.client.consumer.KafkaConsumerRecord<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<TK;TV;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> pause();
    descriptor: ()Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> resume();
    descriptor: ()Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> endHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
            Name  Flags
      endHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscribe(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/lang/String;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
       Name  Flags
      topic  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscribe(java.util.Set<java.lang.String>);
    descriptor: (Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Ljava/lang/String;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
        Name  Flags
      topics  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscribe(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topic              
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscribe(java.util.Set<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topics             
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscribe(java.util.regex.Pattern);
    descriptor: (Ljava/util/regex/Pattern;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/regex/Pattern;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
         Name  Flags
      pattern  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscribe(java.util.regex.Pattern, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/regex/Pattern;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/regex/Pattern;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                   Name  Flags
      pattern            
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> assign(io.vertx.kafka.client.common.TopicPartition);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                Name  Flags
      topicPartition  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> assign(java.util.Set<io.vertx.kafka.client.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> assign(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartition     
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> assign(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> assignment(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<io.vertx.kafka.client.common.TopicPartition>>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> listTopics(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, java.util.List<io.vertx.kafka.client.common.PartitionInfo>>>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> unsubscribe();
    descriptor: ()Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> unsubscribe(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> subscription(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<java.lang.String>>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Ljava/lang/String;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> pause(io.vertx.kafka.client.common.TopicPartition);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                Name  Flags
      topicPartition  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> pause(java.util.Set<io.vertx.kafka.client.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> pause(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartition     
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> pause(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public abstract void paused(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<io.vertx.kafka.client.common.TopicPartition>>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> resume(io.vertx.kafka.client.common.TopicPartition);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                Name  Flags
      topicPartition  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> resume(java.util.Set<io.vertx.kafka.client.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> resume(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartition     
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> resume(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> partitionsRevokedHandler(io.vertx.core.Handler<java.util.Set<io.vertx.kafka.client.common.TopicPartition>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> partitionsAssignedHandler(io.vertx.core.Handler<java.util.Set<io.vertx.kafka.client.common.TopicPartition>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seek(io.vertx.kafka.client.common.TopicPartition, long);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;J)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;J)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                Name  Flags
      topicPartition  
      offset          

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seek(io.vertx.kafka.client.common.TopicPartition, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartition     
      offset             
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToBeginning(io.vertx.kafka.client.common.TopicPartition);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                Name  Flags
      topicPartition  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToBeginning(java.util.Set<io.vertx.kafka.client.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToBeginning(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartition     
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToBeginning(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToEnd(io.vertx.kafka.client.common.TopicPartition);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                Name  Flags
      topicPartition  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToEnd(java.util.Set<io.vertx.kafka.client.common.TopicPartition>);
    descriptor: (Ljava/util/Set;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                 Name  Flags
      topicPartitions  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToEnd(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartition     
      completionHandler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> seekToEnd(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
                   Name  Flags
      topicPartitions    
      completionHandler  

  public abstract void commit();
    descriptor: ()V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public abstract void commit(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  public abstract void commit(java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndMetadata>);
    descriptor: (Ljava/util/Map;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;)V
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
         Name  Flags
      offsets  

  public abstract void commit(java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndMetadata>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndMetadata>>>);
    descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;>;>;)V
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                   Name  Flags
      offsets            
      completionHandler  

  public abstract void committed(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.OffsetAndMetadata>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      handler         

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> partitionsFor(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.client.common.PartitionInfo>>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      topic    
      handler  

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> batchHandler(io.vertx.core.Handler<io.vertx.kafka.client.consumer.KafkaConsumerRecords<K, V>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/kafka/client/consumer/KafkaConsumerRecords<TK;TV;>;>;)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
         Name  Flags
      handler  

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.kafka.client.consumer.KafkaConsumer this
         0: .line 672
            aload 0 /* this */
            aconst_null
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.close:(Lio/vertx/core/Handler;)V
         1: .line 673
            return
        end local 0 // io.vertx.kafka.client.consumer.KafkaConsumer this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;

  public abstract void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  public abstract void position(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)V
    MethodParameters:
           Name  Flags
      partition  
      handler    

  public abstract void offsetsForTimes(java.util.Map<io.vertx.kafka.client.common.TopicPartition, java.lang.Long>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndTimestamp>>>);
    descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;>;>;)V
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                          Name  Flags
      topicPartitionTimestamps  
      handler                   

  public abstract void offsetsForTimes(io.vertx.kafka.client.common.TopicPartition, java.lang.Long, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.OffsetAndTimestamp>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      timestamp       
      handler         

  public abstract void beginningOffsets(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.TopicPartition, java.lang.Long>>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;>;>;)V
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                 Name  Flags
      topicPartitions  
      handler          

  public abstract void beginningOffsets(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      handler         

  public abstract void endOffsets(java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.TopicPartition, java.lang.Long>>>);
    descriptor: (Ljava/util/Set;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;>;>;)V
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    MethodParameters:
                 Name  Flags
      topicPartitions  
      handler          

  public abstract void endOffsets(io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Long>>);
    descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Long;>;>;)V
    MethodParameters:
                Name  Flags
      topicPartition  
      handler         

  public abstract io.vertx.kafka.client.consumer.KafkaReadStream<K, V> asStream();
    descriptor: ()Lio/vertx/kafka/client/consumer/KafkaReadStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/kafka/client/consumer/KafkaReadStream<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()

  public abstract org.apache.kafka.clients.consumer.Consumer<K, V> unwrap();
    descriptor: ()Lorg/apache/kafka/clients/consumer/Consumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lorg/apache/kafka/clients/consumer/Consumer<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.GenIgnore()
    RuntimeVisibleTypeAnnotations: 
      METHOD_RETURN
        io.vertx.codegen.annotations.GenIgnore()

  public abstract io.vertx.kafka.client.consumer.KafkaConsumer<K, V> pollTimeout(long);
    descriptor: (J)Lio/vertx/kafka/client/consumer/KafkaConsumer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (J)Lio/vertx/kafka/client/consumer/KafkaConsumer<TK;TV;>;
    MethodParameters:
         Name  Flags
      timeout  

  public abstract void poll(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.consumer.KafkaConsumerRecords<K, V>>>);
    descriptor: (JLio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/consumer/KafkaConsumerRecords<TK;TV;>;>;>;)V
    MethodParameters:
         Name  Flags
      timeout  
      handler  

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

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

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

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

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

  public io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/streams/ReadStream<Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<TK;TV;>;>;
SourceFile: "KafkaConsumer.java"
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.VertxGen()