public class io.vertx.kafka.client.producer.impl.KafkaProducerImpl<K, V> implements io.vertx.kafka.client.producer.KafkaProducer<K, V>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.kafka.client.producer.impl.KafkaProducerImpl
super_class: java.lang.Object
{
private static final java.util.Map<java.lang.String, io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer> sharedProducers;
descriptor: Ljava/util/Map;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;>;
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.kafka.client.producer.KafkaWriteStream<K, V> stream;
descriptor: Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
private final io.vertx.kafka.client.common.impl.CloseHandler closeHandler;
descriptor: Lio/vertx/kafka/client/common/impl/CloseHandler;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putstatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.sharedProducers:Ljava/util/Map;
return
LocalVariableTable:
Start End Slot Name Signature
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.Properties);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 0
aload 2
invokedynamic get(Lio/vertx/core/Vertx;Ljava/util/Properties;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$0(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaWriteStream; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 config Ljava/util/Properties;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 0
aload 2
invokedynamic get(Lio/vertx/core/Vertx;Ljava/util/Map;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$1(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaWriteStream; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, io.vertx.kafka.client.common.KafkaClientOptions);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 0
aload 2
invokedynamic get(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$2(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/producer/KafkaWriteStream; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 options Lio/vertx/kafka/client/common/KafkaClientOptions;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
options
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.Properties, java.lang.Class<K>, java.lang.Class<V>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 0
aload 2
aload 3
aload 4
invokedynamic get(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$3(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 config Ljava/util/Properties;
0 1 3 keyType Ljava/lang/Class<TK;>;
0 1 4 valueType Ljava/lang/Class<TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Properties;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
keyType
valueType
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.Properties, org.apache.kafka.common.serialization.Serializer<K>, org.apache.kafka.common.serialization.Serializer<V>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 0
aload 2
aload 3
aload 4
invokedynamic get(Lio/vertx/core/Vertx;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$4(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; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 config Ljava/util/Properties;
0 1 3 keySerializer Lorg/apache/kafka/common/serialization/Serializer<TK;>;
0 1 4 valueSerializer Lorg/apache/kafka/common/serialization/Serializer<TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Properties;Lorg/apache/kafka/common/serialization/Serializer<TK;>;Lorg/apache/kafka/common/serialization/Serializer<TV;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
keySerializer
valueSerializer
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.Map<java.lang.String, java.lang.String>, java.lang.Class<K>, java.lang.Class<V>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 0
aload 2
aload 3
aload 4
invokedynamic get(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$5(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 1 3 keyType Ljava/lang/Class<TK;>;
0 1 4 valueType Ljava/lang/Class<TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
keyType
valueType
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.Map<java.lang.String, java.lang.String>, org.apache.kafka.common.serialization.Serializer<K>, org.apache.kafka.common.serialization.Serializer<V>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 0
aload 2
aload 3
aload 4
invokedynamic get(Lio/vertx/core/Vertx;Ljava/util/Map;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$6(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; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 1 3 keySerializer Lorg/apache/kafka/common/serialization/Serializer<TK;>;
0 1 4 valueSerializer Lorg/apache/kafka/common/serialization/Serializer<TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lorg/apache/kafka/common/serialization/Serializer<TK;>;Lorg/apache/kafka/common/serialization/Serializer<TV;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
keySerializer
valueSerializer
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, io.vertx.kafka.client.common.KafkaClientOptions, java.lang.Class<K>, java.lang.Class<V>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 0
aload 2
aload 3
aload 4
invokedynamic get(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class;Ljava/lang/Class;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$7(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 options Lio/vertx/kafka/client/common/KafkaClientOptions;
0 1 3 keyType Ljava/lang/Class<TK;>;
0 1 4 valueType Ljava/lang/Class<TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
options
keyType
valueType
public static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, 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;Ljava/lang/String;Lio/vertx/kafka/client/common/KafkaClientOptions;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 0
aload 2
aload 3
aload 4
invokedynamic get(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Lorg/apache/kafka/common/serialization/Serializer;Lorg/apache/kafka/common/serialization/Serializer;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$8(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; (6)
()Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokestatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 name Ljava/lang/String;
0 1 2 options Lio/vertx/kafka/client/common/KafkaClientOptions;
0 1 3 keySerializer Lorg/apache/kafka/common/serialization/Serializer<TK;>;
0 1 4 valueSerializer Lorg/apache/kafka/common/serialization/Serializer<TV;>;
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;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/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
options
keySerializer
valueSerializer
private static <K, V> io.vertx.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.core.Vertx, java.lang.String, java.util.function.Supplier<io.vertx.kafka.client.producer.KafkaWriteStream>);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=9, locals=7, args_size=3
start local 0 start local 1 start local 2 0: getstatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.sharedProducers:Ljava/util/Map;
dup
astore 3
monitorenter
1: getstatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.sharedProducers:Ljava/util/Map;
aload 1
aload 2
aload 0
invokedynamic apply(Ljava/util/function/Supplier;Lio/vertx/core/Vertx;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$9(Ljava/util/function/Supplier;Lio/vertx/core/Vertx;Ljava/lang/String;)Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer; (6)
(Ljava/lang/String;)Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;
invokeinterface java.util.Map.computeIfAbsent:(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;
checkcast io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer
astore 4
start local 4 2: new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
astore 5
start local 5 3: new io.vertx.kafka.client.producer.impl.KafkaProducerImpl
dup
aload 0
aload 0
aload 4
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.producer:Lorg/apache/kafka/clients/producer/Producer;
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/producer/Producer;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
new io.vertx.kafka.client.common.impl.CloseHandler
dup
aload 4
aload 5
aload 1
invokedynamic accept(Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;Ljava/lang/Object;Ljava/lang/String;)Ljava/util/function/BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$10(Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;Ljava/lang/Object;Ljava/lang/String;Ljava/lang/Long;Lio/vertx/core/Handler;)V (6)
(Ljava/lang/Long;Lio/vertx/core/Handler;)V
invokespecial io.vertx.kafka.client.common.impl.CloseHandler.<init>:(Ljava/util/function/BiConsumer;)V
invokespecial io.vertx.kafka.client.producer.impl.KafkaProducerImpl.<init>:(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/producer/KafkaWriteStream;Lio/vertx/kafka/client/common/impl/CloseHandler;)V
astore 6
start local 6 4: aload 4
aload 5
aload 6
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 6
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.registerCloseHook:()Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl;
aload 3
monitorexit
6: areturn
end local 6 end local 5 end local 4 7: StackMap locals: io.vertx.core.Vertx java.lang.String java.util.function.Supplier java.util.Map
StackMap stack: java.lang.Throwable
aload 3
monitorexit
8: athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 vertx Lio/vertx/core/Vertx;
0 9 1 name Ljava/lang/String;
0 9 2 streamFactory Ljava/util/function/Supplier<Lio/vertx/kafka/client/producer/KafkaWriteStream;>;
2 7 4 sharedProducer Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;
3 7 5 key Ljava/lang/Object;
4 7 6 producer Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Exception table:
from to target type
1 6 7 any
7 8 7 any
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/function/Supplier<Lio/vertx/kafka/client/producer/KafkaWriteStream;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
streamFactory
public void <init>(io.vertx.core.Vertx, io.vertx.kafka.client.producer.KafkaWriteStream<K, V>, io.vertx.kafka.client.common.impl.CloseHandler);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/producer/KafkaWriteStream;Lio/vertx/kafka/client/common/impl/CloseHandler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.vertx:Lio/vertx/core/Vertx;
2: aload 0
aload 2
putfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
3: aload 0
aload 3
putfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 5 1 vertx Lio/vertx/core/Vertx;
0 5 2 stream Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
0 5 3 closeHandler Lio/vertx/kafka/client/common/impl/CloseHandler;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;Lio/vertx/kafka/client/common/impl/CloseHandler;)V
MethodParameters:
Name Flags
vertx
stream
closeHandler
public void <init>(io.vertx.core.Vertx, io.vertx.kafka.client.producer.KafkaWriteStream<K, V>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/producer/KafkaWriteStream;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
new io.vertx.kafka.client.common.impl.CloseHandler
dup
aload 2
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lio/vertx/kafka/client/producer/KafkaWriteStream;)Ljava/util/function/BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/client/producer/KafkaWriteStream.close(JLio/vertx/core/Handler;)V (9 itf)
(Ljava/lang/Long;Lio/vertx/core/Handler;)V
invokespecial io.vertx.kafka.client.common.impl.CloseHandler.<init>:(Ljava/util/function/BiConsumer;)V
invokespecial io.vertx.kafka.client.producer.impl.KafkaProducerImpl.<init>:(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/producer/KafkaWriteStream;Lio/vertx/kafka/client/common/impl/CloseHandler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 vertx Lio/vertx/core/Vertx;
0 2 2 stream Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;)V
MethodParameters:
Name Flags
vertx
stream
public io.vertx.kafka.client.producer.impl.KafkaProducerImpl<K, V> registerCloseHook();
descriptor: ()Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.core.Vertx.currentContext:()Lio/vertx/core/Context;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: aload 0
areturn
3: StackMap locals: io.vertx.core.Context
StackMap stack:
aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
aload 1
checkcast io.vertx.core.impl.ContextInternal
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.registerCloseHook:(Lio/vertx/core/impl/ContextInternal;)V
4: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
1 5 1 context Lio/vertx/core/Context;
Signature: ()Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
public io.vertx.kafka.client.producer.KafkaProducer<K, V> initTransactions(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.initTransactions:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Void> initTransactions();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.initTransactions:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.kafka.client.producer.KafkaProducer<K, V> beginTransaction(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.beginTransaction:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Void> beginTransaction();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.beginTransaction:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.kafka.client.producer.KafkaProducer<K, V> commitTransaction(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.commitTransaction:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Void> commitTransaction();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.commitTransaction:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.kafka.client.producer.KafkaProducer<K, V> abortTransaction(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.abortTransaction:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Void> abortTransaction();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.abortTransaction:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.kafka.client.producer.KafkaProducer<K, V> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.core.Future<java.lang.Void> write(io.vertx.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaProducerRecord.record:()Lorg/apache/kafka/clients/producer/ProducerRecord;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 1 1 kafkaProducerRecord Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
kafkaProducerRecord
public void write(io.vertx.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaProducerRecord.record:()Lorg/apache/kafka/clients/producer/ProducerRecord;
aload 2
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.write:(Ljava/lang/Object;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
record
handler
public io.vertx.core.Future<io.vertx.kafka.client.producer.RecordMetadata> send(io.vertx.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaProducerRecord.record:()Lorg/apache/kafka/clients/producer/ProducerRecord;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.send:(Lorg/apache/kafka/clients/producer/ProducerRecord;)Lio/vertx/core/Future;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/common/impl/Helper.from(Lorg/apache/kafka/clients/producer/RecordMetadata;)Lio/vertx/kafka/client/producer/RecordMetadata; (6)
(Lorg/apache/kafka/clients/producer/RecordMetadata;)Lio/vertx/kafka/client/producer/RecordMetadata;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 1 1 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/vertx/core/Future<Lio/vertx/kafka/client/producer/RecordMetadata;>;
MethodParameters:
Name Flags
record
public io.vertx.kafka.client.producer.KafkaProducer<K, V> send(io.vertx.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.producer.RecordMetadata>>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.send:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/producer/RecordMetadata;>;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/producer/RecordMetadata;>;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
record
handler
public io.vertx.core.Future<java.util.List<io.vertx.kafka.client.common.PartitionInfo>> partitionsFor(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.partitionsFor:(Ljava/lang/String;)Lio/vertx/core/Future;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$13(Ljava/util/List;)Ljava/util/List; (6)
(Ljava/util/List;)Ljava/util/List;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 1 1 topic Ljava/lang/String;
Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;
MethodParameters:
Name Flags
topic
public io.vertx.kafka.client.producer.KafkaProducer<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/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.partitionsFor:(Ljava/lang/String;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 topic Ljava/lang/String;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;>;
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/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
topic
handler
public void end(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.end:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public io.vertx.kafka.client.producer.KafkaProducer<K, V> setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
iload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.setWriteQueueMaxSize:(I)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 size I
Signature: (I)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
size
public boolean writeQueueFull();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.writeQueueFull:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
public io.vertx.kafka.client.producer.KafkaProducer<K, V> drainHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.kafka.client.producer.KafkaProducer<K, V> flush(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
aload 1
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.flush:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
pop
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.Future<java.lang.Void> flush();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.flush:()Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.core.Future<java.lang.Void> close(long);
descriptor: (J)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 3
start local 3 1: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
lload 1
aload 3
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.close:(JLio/vertx/core/Handler;)V
2: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 3 1 timeout J
1 3 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (J)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
timeout
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 1
start local 1 1: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
aload 1
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.close:(Lio/vertx/core/Handler;)V
2: aload 1
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
1 3 1 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
aload 1
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.close:(Lio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
public void close(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (JLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
aload 3
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.close:(Lio/vertx/core/Handler;)V
1: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
0 2 1 timeout J
0 2 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
timeout
completionHandler
public io.vertx.kafka.client.producer.KafkaWriteStream<K, V> asStream();
descriptor: ()Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lio/vertx/kafka/client/producer/KafkaWriteStream<TK;TV;>;
public org.apache.kafka.clients.producer.Producer<K, V> unwrap();
descriptor: ()Lorg/apache/kafka/clients/producer/Producer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl.stream:Lio/vertx/kafka/client/producer/KafkaWriteStream;
invokeinterface io.vertx.kafka.client.producer.KafkaWriteStream.unwrap:()Lorg/apache/kafka/clients/producer/Producer;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl<TK;TV;>;
Signature: ()Lorg/apache/kafka/clients/producer/Producer<TK;TV;>;
public void write(java.lang.Object, io.vertx.core.Handler);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast io.vertx.kafka.client.producer.KafkaProducerRecord
aload 2
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.write:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)V
return
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.Future write(java.lang.Object);
descriptor: (Ljava/lang/Object;)Lio/vertx/core/Future;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.kafka.client.producer.KafkaProducerRecord
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.write:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Future;
areturn
LocalVariableTable:
Start End Slot Name Signature
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: aload 0
iload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.setWriteQueueMaxSize:(I)Lio/vertx/kafka/client/producer/KafkaProducer;
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: aload 0
aload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
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: aload 0
aload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
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: aload 0
aload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl.drainHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/producer/KafkaProducer;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$0(io.vertx.core.Vertx, java.util.Properties);
descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$1(io.vertx.core.Vertx, java.util.Map);
descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
0: aload 0
new java.util.HashMap
dup
aload 1
invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$2(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: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$3(io.vertx.core.Vertx, java.util.Properties, java.lang.Class, java.lang.Class);
descriptor: (Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
aload 3
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$4(io.vertx.core.Vertx, java.util.Properties, org.apache.kafka.common.serialization.Serializer, org.apache.kafka.common.serialization.Serializer);
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: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
aload 3
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
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$5(io.vertx.core.Vertx, java.util.Map, java.lang.Class, java.lang.Class);
descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
new java.util.HashMap
dup
aload 1
invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
aload 2
aload 3
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$6(io.vertx.core.Vertx, java.util.Map, org.apache.kafka.common.serialization.Serializer, org.apache.kafka.common.serialization.Serializer);
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: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
new java.util.HashMap
dup
aload 1
invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
aload 2
aload 3
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
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$7(io.vertx.core.Vertx, io.vertx.kafka.client.common.KafkaClientOptions, java.lang.Class, java.lang.Class);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
aload 3
invokestatic io.vertx.kafka.client.producer.KafkaWriteStream.create:(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/common/KafkaClientOptions;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaWriteStream;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.KafkaWriteStream lambda$8(io.vertx.core.Vertx, io.vertx.kafka.client.common.KafkaClientOptions, org.apache.kafka.common.serialization.Serializer, org.apache.kafka.common.serialization.Serializer);
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: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
0: aload 0
aload 1
aload 2
aload 3
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
LocalVariableTable:
Start End Slot Name Signature
private static io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer lambda$9(java.util.function.Supplier, io.vertx.core.Vertx, java.lang.String);
descriptor: (Ljava/util/function/Supplier;Lio/vertx/core/Vertx;Ljava/lang/String;)Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=3
start local 2 0: aload 0
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast io.vertx.kafka.client.producer.KafkaWriteStream
astore 3
start local 3 1: new io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer
dup
aload 3
invokespecial io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.<init>:(Lio/vertx/kafka/client/producer/KafkaWriteStream;)V
astore 4
start local 4 2: aload 4
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
aload 1
checkcast io.vertx.core.impl.VertxInternal
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.registerCloseHook:(Lio/vertx/core/impl/VertxInternal;)V
3: aload 4
areturn
end local 4 end local 3 end local 2 LocalVariableTable:
Start End Slot Name Signature
0 4 2 key Ljava/lang/String;
1 4 3 stream Lio/vertx/kafka/client/producer/KafkaWriteStream;
2 4 4 s Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;
private static void lambda$10(io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer, java.lang.Object, java.lang.String, java.lang.Long, io.vertx.core.Handler);
descriptor: (Lio/vertx/kafka/client/producer/impl/KafkaProducerImpl$SharedProducer;Ljava/lang/Object;Ljava/lang/String;Ljava/lang/Long;Lio/vertx/core/Handler;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=6, args_size=5
start local 3 start local 4 0: getstatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.sharedProducers:Ljava/util/Map;
dup
astore 5
monitorenter
1: aload 0
aload 1
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
invokevirtual io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.isEmpty:()Z
ifeq 7
3: getstatic io.vertx.kafka.client.producer.impl.KafkaProducerImpl.sharedProducers:Ljava/util/Map;
aload 2
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 0
getfield io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer.closeHandler:Lio/vertx/kafka/client/common/impl/CloseHandler;
aload 3
invokevirtual java.lang.Long.longValue:()J
aload 4
invokevirtual io.vertx.kafka.client.common.impl.CloseHandler.close:(JLio/vertx/core/Handler;)V
5: aload 5
monitorexit
6: return
7: StackMap locals: java.util.Map
StackMap stack:
aload 5
monitorexit
8: goto 11
StackMap locals:
StackMap stack: java.lang.Throwable
9: aload 5
monitorexit
10: athrow
11: StackMap locals:
StackMap stack:
aload 4
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
12: return
end local 4 end local 3 LocalVariableTable:
Start End Slot Name Signature
0 13 3 timeout Ljava/lang/Long;
0 13 4 ar Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Exception table:
from to target type
1 6 9 any
7 8 9 any
9 10 9 any
private static java.util.List lambda$13(java.util.List);
descriptor: (Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/producer/impl/KafkaProducerImpl.lambda$14(Lorg/apache/kafka/common/PartitionInfo;)Lio/vertx/kafka/client/common/PartitionInfo; (6)
(Lorg/apache/kafka/common/PartitionInfo;)Lio/vertx/kafka/client/common/PartitionInfo;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
1: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 list Ljava/util/List<Lorg/apache/kafka/common/PartitionInfo;>;
private static io.vertx.kafka.client.common.PartitionInfo lambda$14(org.apache.kafka.common.PartitionInfo);
descriptor: (Lorg/apache/kafka/common/PartitionInfo;)Lio/vertx/kafka/client/common/PartitionInfo;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new io.vertx.kafka.client.common.PartitionInfo
dup
invokespecial io.vertx.kafka.client.common.PartitionInfo.<init>:()V
1: aload 0
invokevirtual org.apache.kafka.common.PartitionInfo.inSyncReplicas:()[Lorg/apache/kafka/common/Node;
invokestatic java.util.stream.Stream.of:([Ljava/lang/Object;)Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/common/impl/Helper.from(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node; (6)
(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
2: invokevirtual io.vertx.kafka.client.common.PartitionInfo.setInSyncReplicas:(Ljava/util/List;)Lio/vertx/kafka/client/common/PartitionInfo;
3: aload 0
invokevirtual org.apache.kafka.common.PartitionInfo.leader:()Lorg/apache/kafka/common/Node;
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokevirtual io.vertx.kafka.client.common.PartitionInfo.setLeader:(Lio/vertx/kafka/client/common/Node;)Lio/vertx/kafka/client/common/PartitionInfo;
4: aload 0
invokevirtual org.apache.kafka.common.PartitionInfo.partition:()I
invokevirtual io.vertx.kafka.client.common.PartitionInfo.setPartition:(I)Lio/vertx/kafka/client/common/PartitionInfo;
5: aload 0
invokevirtual org.apache.kafka.common.PartitionInfo.replicas:()[Lorg/apache/kafka/common/Node;
invokestatic java.util.stream.Stream.of:([Ljava/lang/Object;)Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/common/impl/Helper.from(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node; (6)
(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
6: invokevirtual io.vertx.kafka.client.common.PartitionInfo.setReplicas:(Ljava/util/List;)Lio/vertx/kafka/client/common/PartitionInfo;
7: aload 0
invokevirtual org.apache.kafka.common.PartitionInfo.topic:()Ljava/lang/String;
invokevirtual io.vertx.kafka.client.common.PartitionInfo.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/PartitionInfo;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 kafkaPartitionInfo Lorg/apache/kafka/common/PartitionInfo;
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
SourceFile: "KafkaProducerImpl.java"
NestMembers:
io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer
InnerClasses:
private SharedProducer = io.vertx.kafka.client.producer.impl.KafkaProducerImpl$SharedProducer of io.vertx.kafka.client.producer.impl.KafkaProducerImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
KafkaProducerImpl
sharedProducers: Map
<clinit>(): void
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)