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.producer.KafkaWriteStream<K, V> extends io.vertx.core.streams.WriteStream<org.apache.kafka.clients.producer.ProducerRecord<K, V>>
  minor version: 0
  major version: 59
  flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
  this_class: io.vertx.kafka.client.producer.KafkaWriteStream
  super_class: java.lang.Object
{
  public static final int DEFAULT_MAX_SIZE;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 1048576

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, java.util.Properties);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Properties config
         0: .line 58
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
         1: .line 59
            aload 0 /* vertx */
         2: .line 60
            new org.apache.kafka.clients.producer.KafkaProducer
            dup
            aload 1 /* config */
            invokespecial org.apache.kafka.clients.producer.KafkaProducer.<init>:(Ljava/util/Properties;)V
         3: .line 61
            aload 1 /* config */
            iconst_1
            invokestatic io.vertx.kafka.client.common.KafkaClientOptions.fromProperties:(Ljava/util/Properties;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
         4: .line 58
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 1 // java.util.Properties config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0   vertx  Lio/vertx/core/Vertx;
            0    5     1  config  Ljava/util/Properties;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
        Name  Flags
      vertx   
      config  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<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/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=6, 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 74
            aload 2 /* keyType */
            invokestatic io.vertx.kafka.client.serialization.VertxSerdes.serdeFrom:(Ljava/lang/Class;)Lorg/apache/kafka/common/serialization/Serde;
            invokeinterface org.apache.kafka.common.serialization.Serde.serializer:()Lorg/apache/kafka/common/serialization/Serializer;
            astore 4 /* keySerializer */
        start local 4 // org.apache.kafka.common.serialization.Serializer keySerializer
         1: .line 75
            aload 3 /* valueType */
            invokestatic io.vertx.kafka.client.serialization.VertxSerdes.serdeFrom:(Ljava/lang/Class;)Lorg/apache/kafka/common/serialization/Serde;
            invokeinterface org.apache.kafka.common.serialization.Serde.serializer:()Lorg/apache/kafka/common/serialization/Serializer;
            astore 5 /* valueSerializer */
        start local 5 // org.apache.kafka.common.serialization.Serializer valueSerializer
         2: .line 76
            aload 0 /* vertx */
            aload 1 /* config */
            aload 4 /* keySerializer */
            aload 5 /* valueSerializer */
            invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            areturn
        end local 5 // org.apache.kafka.common.serialization.Serializer valueSerializer
        end local 4 // org.apache.kafka.common.serialization.Serializer keySerializer
        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    3     0            vertx  Lio/vertx/core/Vertx;
            0    3     1           config  Ljava/util/Properties;
            0    3     2          keyType  Ljava/lang/Class<TK;>;
            0    3     3        valueType  Ljava/lang/Class<TV;>;
            1    3     4    keySerializer  Lorg/apache/kafka/common/serialization/Serializer<TK;>;
            2    3     5  valueSerializer  Lorg/apache/kafka/common/serialization/Serializer<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/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
           Name  Flags
      vertx      
      config     
      keyType    
      valueType  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, java.util.Properties, org.apache.kafka.common.serialization.Serializer<K>, org.apache.kafka.common.serialization.Serializer<V>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=4, 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.Serializer keySerializer
        start local 3 // org.apache.kafka.common.serialization.Serializer valueSerializer
         0: .line 89
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
         1: .line 90
            aload 0 /* vertx */
         2: .line 91
            new org.apache.kafka.clients.producer.KafkaProducer
            dup
            aload 1 /* config */
            aload 2 /* keySerializer */
            aload 3 /* valueSerializer */
            invokespecial org.apache.kafka.clients.producer.KafkaProducer.<init>:(Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)V
         3: .line 92
            aload 1 /* config */
            iconst_1
            invokestatic io.vertx.kafka.client.common.KafkaClientOptions.fromProperties:(Ljava/util/Properties;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
         4: .line 89
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 3 // org.apache.kafka.common.serialization.Serializer valueSerializer
        end local 2 // org.apache.kafka.common.serialization.Serializer keySerializer
        end local 1 // java.util.Properties config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    5     0            vertx  Lio/vertx/core/Vertx;
            0    5     1           config  Ljava/util/Properties;
            0    5     2    keySerializer  Lorg/apache/kafka/common/serialization/Serializer<TK;>;
            0    5     3  valueSerializer  Lorg/apache/kafka/common/serialization/Serializer<TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer<TK;>;Lorg/apache/kafka/common/serialization/Serializer<TV;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
                 Name  Flags
      vertx            
      config           
      keySerializer    
      valueSerializer  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.Object>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // java.util.Map config
         0: .line 103
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
         1: .line 104
            aload 0 /* vertx */
         2: .line 105
            new org.apache.kafka.clients.producer.KafkaProducer
            dup
            aload 1 /* config */
            invokespecial org.apache.kafka.clients.producer.KafkaProducer.<init>:(Ljava/util/Map;)V
         3: .line 106
            aload 1 /* config */
            iconst_1
            invokestatic io.vertx.kafka.client.common.KafkaClientOptions.fromMap:(Ljava/util/Map;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
         4: .line 103
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 1 // java.util.Map config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0   vertx  Lio/vertx/core/Vertx;
            0    5     1  config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
        Name  Flags
      vertx   
      config  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.Object>, 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/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=6, 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 119
            aload 2 /* keyType */
            invokestatic io.vertx.kafka.client.serialization.VertxSerdes.serdeFrom:(Ljava/lang/Class;)Lorg/apache/kafka/common/serialization/Serde;
            invokeinterface org.apache.kafka.common.serialization.Serde.serializer:()Lorg/apache/kafka/common/serialization/Serializer;
            astore 4 /* keySerializer */
        start local 4 // org.apache.kafka.common.serialization.Serializer keySerializer
         1: .line 120
            aload 3 /* valueType */
            invokestatic io.vertx.kafka.client.serialization.VertxSerdes.serdeFrom:(Ljava/lang/Class;)Lorg/apache/kafka/common/serialization/Serde;
            invokeinterface org.apache.kafka.common.serialization.Serde.serializer:()Lorg/apache/kafka/common/serialization/Serializer;
            astore 5 /* valueSerializer */
        start local 5 // org.apache.kafka.common.serialization.Serializer valueSerializer
         2: .line 121
            aload 0 /* vertx */
            aload 1 /* config */
            aload 4 /* keySerializer */
            aload 5 /* valueSerializer */
            invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            areturn
        end local 5 // org.apache.kafka.common.serialization.Serializer valueSerializer
        end local 4 // org.apache.kafka.common.serialization.Serializer keySerializer
        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    3     0            vertx  Lio/vertx/core/Vertx;
            0    3     1           config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
            0    3     2          keyType  Ljava/lang/Class<TK;>;
            0    3     3        valueType  Ljava/lang/Class<TV;>;
            1    3     4    keySerializer  Lorg/apache/kafka/common/serialization/Serializer<TK;>;
            2    3     5  valueSerializer  Lorg/apache/kafka/common/serialization/Serializer<TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
           Name  Flags
      vertx      
      config     
      keyType    
      valueType  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.Object>, org.apache.kafka.common.serialization.Serializer<K>, org.apache.kafka.common.serialization.Serializer<V>);
    descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=4, 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.Serializer keySerializer
        start local 3 // org.apache.kafka.common.serialization.Serializer valueSerializer
         0: .line 134
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
         1: .line 135
            aload 0 /* vertx */
         2: .line 136
            new org.apache.kafka.clients.producer.KafkaProducer
            dup
            aload 1 /* config */
            aload 2 /* keySerializer */
            aload 3 /* valueSerializer */
            invokespecial org.apache.kafka.clients.producer.KafkaProducer.<init>:(Ljava/util/Map;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)V
         3: .line 137
            aload 1 /* config */
            iconst_1
            invokestatic io.vertx.kafka.client.common.KafkaClientOptions.fromMap:(Ljava/util/Map;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
         4: .line 134
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 3 // org.apache.kafka.common.serialization.Serializer valueSerializer
        end local 2 // org.apache.kafka.common.serialization.Serializer keySerializer
        end local 1 // java.util.Map config
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    5     0            vertx  Lio/vertx/core/Vertx;
            0    5     1           config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
            0    5     2    keySerializer  Lorg/apache/kafka/common/serialization/Serializer<TK;>;
            0    5     3  valueSerializer  Lorg/apache/kafka/common/serialization/Serializer<TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;Lorg/apache/kafka/common/serialization/Serializer<TK;>;Lorg/apache/kafka/common/serialization/Serializer<TV;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
                 Name  Flags
      vertx            
      config           
      keySerializer    
      valueSerializer  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, io.vertx.kafka.client.common.KafkaClientOptions);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=3, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // io.vertx.kafka.client.common.KafkaClientOptions options
         0: .line 148
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 2 /* config */
        start local 2 // java.util.Map config
         1: .line 149
            aload 1 /* options */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getConfig:()Ljava/util/Map;
            ifnull 3
         2: .line 150
            aload 2 /* config */
            aload 1 /* options */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getConfig:()Ljava/util/Map;
            invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
         3: .line 152
      StackMap locals: java.util.Map
      StackMap stack:
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
            aload 0 /* vertx */
            new org.apache.kafka.clients.producer.KafkaProducer
            dup
            aload 2 /* config */
            invokespecial org.apache.kafka.clients.producer.KafkaProducer.<init>:(Ljava/util/Map;)V
            aload 1 /* options */
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 2 // java.util.Map config
        end local 1 // io.vertx.kafka.client.common.KafkaClientOptions options
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0    vertx  Lio/vertx/core/Vertx;
            0    4     1  options  Lio/vertx/kafka/client/common/KafkaClientOptions;
            1    4     2   config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      vertx    
      options  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, io.vertx.kafka.client.common.KafkaClientOptions, java.lang.Class<K>, java.lang.Class<V>);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=6, args_size=4
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // io.vertx.kafka.client.common.KafkaClientOptions options
        start local 2 // java.lang.Class keyType
        start local 3 // java.lang.Class valueType
         0: .line 165
            aload 2 /* keyType */
            invokestatic io.vertx.kafka.client.serialization.VertxSerdes.serdeFrom:(Ljava/lang/Class;)Lorg/apache/kafka/common/serialization/Serde;
            invokeinterface org.apache.kafka.common.serialization.Serde.serializer:()Lorg/apache/kafka/common/serialization/Serializer;
            astore 4 /* keySerializer */
        start local 4 // org.apache.kafka.common.serialization.Serializer keySerializer
         1: .line 166
            aload 3 /* valueType */
            invokestatic io.vertx.kafka.client.serialization.VertxSerdes.serdeFrom:(Ljava/lang/Class;)Lorg/apache/kafka/common/serialization/Serde;
            invokeinterface org.apache.kafka.common.serialization.Serde.serializer:()Lorg/apache/kafka/common/serialization/Serializer;
            astore 5 /* valueSerializer */
        start local 5 // org.apache.kafka.common.serialization.Serializer valueSerializer
         2: .line 167
            aload 0 /* vertx */
            aload 1 /* options */
            aload 4 /* keySerializer */
            aload 5 /* valueSerializer */
            invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            areturn
        end local 5 // org.apache.kafka.common.serialization.Serializer valueSerializer
        end local 4 // org.apache.kafka.common.serialization.Serializer keySerializer
        end local 3 // java.lang.Class valueType
        end local 2 // java.lang.Class keyType
        end local 1 // io.vertx.kafka.client.common.KafkaClientOptions options
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    3     0            vertx  Lio/vertx/core/Vertx;
            0    3     1          options  Lio/vertx/kafka/client/common/KafkaClientOptions;
            0    3     2          keyType  Ljava/lang/Class<TK;>;
            0    3     3        valueType  Ljava/lang/Class<TV;>;
            1    3     4    keySerializer  Lorg/apache/kafka/common/serialization/Serializer<TK;>;
            2    3     5  valueSerializer  Lorg/apache/kafka/common/serialization/Serializer<TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
           Name  Flags
      vertx      
      options    
      keyType    
      valueType  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, io.vertx.kafka.client.common.KafkaClientOptions, org.apache.kafka.common.serialization.Serializer<K>, org.apache.kafka.common.serialization.Serializer<V>);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=5, args_size=4
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // io.vertx.kafka.client.common.KafkaClientOptions options
        start local 2 // org.apache.kafka.common.serialization.Serializer keySerializer
        start local 3 // org.apache.kafka.common.serialization.Serializer valueSerializer
         0: .line 180
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 4 /* config */
        start local 4 // java.util.Map config
         1: .line 181
            aload 1 /* options */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getConfig:()Ljava/util/Map;
            ifnull 3
         2: .line 182
            aload 4 /* config */
            aload 1 /* options */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getConfig:()Ljava/util/Map;
            invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
         3: .line 184
      StackMap locals: java.util.Map
      StackMap stack:
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
         4: .line 185
            aload 0 /* vertx */
         5: .line 186
            new org.apache.kafka.clients.producer.KafkaProducer
            dup
            aload 4 /* config */
            aload 2 /* keySerializer */
            aload 3 /* valueSerializer */
            invokespecial org.apache.kafka.clients.producer.KafkaProducer.<init>:(Ljava/util/Map;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)V
         6: .line 187
            aload 1 /* options */
         7: .line 184
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 4 // java.util.Map config
        end local 3 // org.apache.kafka.common.serialization.Serializer valueSerializer
        end local 2 // org.apache.kafka.common.serialization.Serializer keySerializer
        end local 1 // io.vertx.kafka.client.common.KafkaClientOptions options
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    8     0            vertx  Lio/vertx/core/Vertx;
            0    8     1          options  Lio/vertx/kafka/client/common/KafkaClientOptions;
            0    8     2    keySerializer  Lorg/apache/kafka/common/serialization/Serializer<TK;>;
            0    8     3  valueSerializer  Lorg/apache/kafka/common/serialization/Serializer<TV;>;
            1    8     4           config  Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Lorg/apache/kafka/common/serialization/Serializer<TK;>;Lorg/apache/kafka/common/serialization/Serializer<TV;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
                 Name  Flags
      vertx            
      options          
      keySerializer    
      valueSerializer  

  public static <K, V> io.vertx.kafka.client.producer.KafkaWriteStream<K, V> create(io.vertx.core.Vertx, org.apache.kafka.clients.producer.Producer<K, V>);
    descriptor: (Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=2, args_size=2
        start local 0 // io.vertx.core.Vertx vertx
        start local 1 // org.apache.kafka.clients.producer.Producer producer
         0: .line 197
            new io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl
            dup
            aload 0 /* vertx */
            aload 1 /* producer */
            new io.vertx.kafka.client.common.KafkaClientOptions
            dup
            invokespecial io.vertx.kafka.client.common.KafkaClientOptions.<init>:()V
            invokespecial io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl.<init>:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
            areturn
        end local 1 // org.apache.kafka.clients.producer.Producer producer
        end local 0 // io.vertx.core.Vertx vertx
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    1     0     vertx  Lio/vertx/core/Vertx;
            0    1     1  producer  Lorg/apache/kafka/clients/producer/Producer<TK;TV;>;
    Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer<TK;TV;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
          Name  Flags
      vertx     
      producer  

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

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> setWriteQueueMaxSize(int);
    descriptor: (I)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (I)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    RuntimeVisibleAnnotations: 
      io.vertx.codegen.annotations.Fluent()
    MethodParameters:
      Name  Flags
      i     

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

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> initTransactions(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.core.Future<java.lang.Void> initTransactions();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> beginTransaction(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.core.Future<java.lang.Void> beginTransaction();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> commitTransaction(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.core.Future<java.lang.Void> commitTransaction();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> abortTransaction(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      handler  

  public abstract io.vertx.core.Future<java.lang.Void> abortTransaction();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public abstract io.vertx.core.Future<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord<K, V>);
    descriptor: (Lorg/apache/kafka/clients/producer/ProducerRecord;)Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lorg/apache/kafka/clients/producer/ProducerRecord<TK;TV;>;)Lio/vertx/core/Future<Lorg/apache/kafka/clients/producer/RecordMetadata;>;
    MethodParameters:
        Name  Flags
      record  

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> send(org.apache.kafka.clients.producer.ProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<org.apache.kafka.clients.producer.RecordMetadata>>);
    descriptor: (Lorg/apache/kafka/clients/producer/ProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lorg/apache/kafka/clients/producer/ProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lorg/apache/kafka/clients/producer/RecordMetadata;>;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
         Name  Flags
      record   
      handler  

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

  public abstract io.vertx.core.Future<java.util.List<org.apache.kafka.common.PartitionInfo>> partitionsFor(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;>;
    MethodParameters:
       Name  Flags
      topic  

  public abstract io.vertx.kafka.client.producer.KafkaWriteStream<K, V> flush(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
    MethodParameters:
                   Name  Flags
      completionHandler  

  public abstract io.vertx.core.Future<java.lang.Void> flush();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public abstract io.vertx.core.Future<java.lang.Void> close();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  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 close(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (JLio/vertx/core/Handler;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
                   Name  Flags
      timeout            
      completionHandler  

  public abstract io.vertx.core.Future<java.lang.Void> close(long);
    descriptor: (J)Lio/vertx/core/Future;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (J)Lio/vertx/core/Future<Ljava/lang/Void;>;
    MethodParameters:
         Name  Flags
      timeout  

  public abstract org.apache.kafka.clients.producer.Producer<K, V> unwrap();
    descriptor: ()Lorg/apache/kafka/clients/producer/Producer;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Lorg/apache/kafka/clients/producer/Producer<TK;TV;>;

  public io.vertx.core.streams.WriteStream setWriteQueueMaxSize(int);
    descriptor: (I)Lio/vertx/core/streams/WriteStream;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            iload 1
            invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.setWriteQueueMaxSize:(I)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            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.producer.KafkaWriteStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.WriteStream exceptionHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
    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.producer.KafkaWriteStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public io.vertx.core.streams.WriteStream drainHandler(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/WriteStream;
    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.producer.KafkaWriteStream.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/streams/WriteStream<Lorg/apache/kafka/clients/producer/ProducerRecord<TK;TV;>;>;
SourceFile: "KafkaWriteStream.java"