public class io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> implements io.vertx.reactivex.core.streams.WriteStream<io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.reactivex.kafka.client.producer.KafkaProducer
super_class: java.lang.Object
{
public static final io.vertx.lang.rx.TypeArg<io.vertx.reactivex.kafka.client.producer.KafkaProducer> __TYPE_ARG;
descriptor: Lio/vertx/lang/rx/TypeArg;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
Signature: Lio/vertx/lang/rx/TypeArg<Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;>;
private final io.vertx.kafka.client.producer.KafkaProducer<K, V> delegate;
descriptor: Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/kafka/client/producer/KafkaProducer<TK;TV;>;
public final io.vertx.lang.rx.TypeArg<K> __typeArg_0;
descriptor: Lio/vertx/lang/rx/TypeArg;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lio/vertx/lang/rx/TypeArg<TK;>;
public final io.vertx.lang.rx.TypeArg<V> __typeArg_1;
descriptor: Lio/vertx/lang/rx/TypeArg;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Signature: Lio/vertx/lang/rx/TypeArg<TV;>;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
public boolean equals(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
o
public int hashCode();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
public void <init>(io.vertx.kafka.client.producer.KafkaProducer);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.reactivex.WriteStreamObserver cannot be resolved to a type\n\tio.vertx.reactivex.WriteStreamSubscriber cannot be resolved to a type\n\tio.vertx.reactivex.WriteStreamObserver cannot be resolved to a type\n\tobserver cannot be resolved to a variable\n\tobserver cannot be resolved to a variable\n\tio.vertx.reactivex.RxHelper cannot be resolved to a type\n\tobserver cannot be resolved to a variable\n\tio.vertx.reactivex.WriteStreamSubscriber cannot be resolved to a type\n\tsubscriber cannot be resolved to a variable\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.reactivex.RxHelper cannot be resolved to a type\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
delegate
public void <init>(io.vertx.kafka.client.producer.KafkaProducer, io.vertx.lang.rx.TypeArg<K>, io.vertx.lang.rx.TypeArg<V>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg;Lio/vertx/lang/rx/TypeArg;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.reactivex.WriteStreamObserver cannot be resolved to a type\n\tio.vertx.reactivex.WriteStreamSubscriber cannot be resolved to a type\n\tio.vertx.reactivex.WriteStreamObserver cannot be resolved to a type\n\tobserver cannot be resolved to a variable\n\tobserver cannot be resolved to a variable\n\tio.vertx.reactivex.RxHelper cannot be resolved to a type\n\tobserver cannot be resolved to a variable\n\tio.vertx.reactivex.WriteStreamSubscriber cannot be resolved to a type\n\tsubscriber cannot be resolved to a variable\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.reactivex.RxHelper cannot be resolved to a type\n\tsubscriber cannot be resolved to a variable\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg<TK;>;Lio/vertx/lang/rx/TypeArg<TV;>;)V
MethodParameters:
Name Flags
delegate
typeArg_0
typeArg_1
public io.vertx.kafka.client.producer.KafkaProducer getDelegate();
descriptor: ()Lio/vertx/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
public void end();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
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=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public io.reactivex.Completable rxEnd();
descriptor: ()Lio/reactivex/Completable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
public void end(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)V
MethodParameters:
Name Flags
data
public void end(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
data
handler
public io.reactivex.Completable rxEnd(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;)Lio/reactivex/Completable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/reactivex/Completable;
MethodParameters:
Name Flags
data
public static <K, V> io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.reactivex.core.Vertx, java.lang.String, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/reactivex/core/Vertx;Ljava/lang/String;Ljava/util/Map;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/reactivex/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
public static <K, V> io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> createShared(io.vertx.reactivex.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/reactivex/core/Vertx;Ljava/lang/String;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=5
0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/reactivex/core/Vertx;Ljava/lang/String;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
name
config
keyType
valueType
public static <K, V> io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> create(io.vertx.reactivex.core.Vertx, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/reactivex/core/Vertx;Ljava/util/Map;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/reactivex/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
config
public static <K, V> io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> create(io.vertx.reactivex.core.Vertx, java.util.Map<java.lang.String, java.lang.String>, java.lang.Class<K>, java.lang.Class<V>);
descriptor: (Lio/vertx/reactivex/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=4
0: new java.lang.Error
dup
ldc "Unresolved compilation problems: \n\tio.vertx.lang.reactivex cannot be resolved\n\tio.vertx.lang.reactivex cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/reactivex/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/Class<TK;>;Ljava/lang/Class<TV;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
vertx
config
keyType
valueType
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> write(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
kafkaProducerRecord
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> setWriteQueueMaxSize(int);
descriptor: (I)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (I)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
i
public boolean writeQueueFull();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> drainHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
handler
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> write(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
data
handler
public io.reactivex.Completable rxWrite(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;)Lio/reactivex/Completable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/reactivex/Completable;
MethodParameters:
Name Flags
data
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> send(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
record
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> send(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.client.producer.RecordMetadata>>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;Lio/vertx/core/Handler;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/client/producer/RecordMetadata;>;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
record
handler
public io.reactivex.Single<io.vertx.kafka.client.producer.RecordMetadata> rxSend(io.vertx.reactivex.kafka.client.producer.KafkaProducerRecord<K, V>);
descriptor: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord;)Lio/reactivex/Single;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;)Lio/reactivex/Single<Lio/vertx/kafka/client/producer/RecordMetadata;>;
MethodParameters:
Name Flags
record
public io.vertx.reactivex.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/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
topic
handler
public io.reactivex.Single<java.util.List<io.vertx.kafka.client.common.PartitionInfo>> rxPartitionsFor(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/reactivex/Single;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Ljava/lang/String;)Lio/reactivex/Single<Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;
MethodParameters:
Name Flags
topic
public io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> flush(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
completionHandler
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
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=3, locals=2, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
completionHandler
public io.reactivex.Completable rxClose();
descriptor: ()Lio/reactivex/Completable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
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=3, locals=4, args_size=3
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
timeout
completionHandler
public io.reactivex.Completable rxClose(long);
descriptor: (J)Lio/reactivex/Completable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n\tio.vertx.reactivex.impl cannot be resolved\n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
timeout
public static <K, V> io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> newInstance(io.vertx.kafka.client.producer.KafkaProducer);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/kafka/client/producer/KafkaProducer;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
arg
public static <K, V> io.vertx.reactivex.kafka.client.producer.KafkaProducer<K, V> newInstance(io.vertx.kafka.client.producer.KafkaProducer, io.vertx.lang.rx.TypeArg<K>, io.vertx.lang.rx.TypeArg<V>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg;Lio/vertx/lang/rx/TypeArg;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
0: new java.lang.Error
dup
ldc "Unresolved compilation problem: \n"
invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>(Lio/vertx/kafka/client/producer/KafkaProducer;Lio/vertx/lang/rx/TypeArg<TK;>;Lio/vertx/lang/rx/TypeArg<TV;>;)Lio/vertx/reactivex/kafka/client/producer/KafkaProducer<TK;TV;>;
MethodParameters:
Name Flags
arg
__typeArg_K
__typeArg_V
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/reactivex/core/streams/WriteStream<Lio/vertx/reactivex/kafka/client/producer/KafkaProducerRecord<TK;TV;>;>;
SourceFile: "KafkaProducer.java"
RuntimeVisibleAnnotations:
io.vertx.lang.rx.RxGen(value = Lio/vertx/kafka/client/producer/KafkaProducer;)
KafkaProducer
delegate: KafkaProducer
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-rx/vertx-rx-java2: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)