public class examples.VertxKafkaClientExamples
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: examples.VertxKafkaClientExamples
super_class: java.lang.Object
{
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lexamples/VertxKafkaClientExamples;
public void exampleCreateConsumerJava(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new java.util.Properties
dup
invokespecial java.util.Properties.<init>:()V
astore 2
start local 2 1: aload 2
ldc "bootstrap.servers"
ldc "localhost:9092"
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ldc "key.deserializer"
ldc Lorg/apache/kafka/common/serialization/StringDeserializer;
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 2
ldc "value.deserializer"
ldc Lorg/apache/kafka/common/serialization/StringDeserializer;
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 2
ldc "group.id"
ldc "my_group"
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 2
ldc "auto.offset.reset"
ldc "earliest"
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 2
ldc "enable.auto.commit"
ldc "false"
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 1
aload 2
invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lexamples/VertxKafkaClientExamples;
0 9 1 vertx Lio/vertx/core/Vertx;
1 9 2 config Ljava/util/Properties;
MethodParameters:
Name Flags
vertx
public void exampleCreateConsumer(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 1: aload 2
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ldc "key.deserializer"
ldc "org.apache.kafka.common.serialization.StringDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 2
ldc "value.deserializer"
ldc "org.apache.kafka.common.serialization.StringDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 2
ldc "group.id"
ldc "my_group"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 2
ldc "auto.offset.reset"
ldc "earliest"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 2
ldc "enable.auto.commit"
ldc "false"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 1
aload 2
invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lexamples/VertxKafkaClientExamples;
0 9 1 vertx Lio/vertx/core/Vertx;
1 9 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
vertx
public void createProducer(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 1: aload 2
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ldc "key.serializer"
ldc "org.apache.kafka.common.serialization.StringSerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 2
ldc "value.serializer"
ldc "org.apache.kafka.common.serialization.StringSerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 2
ldc "acks"
ldc "1"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 1
aload 2
invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaProducer;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lexamples/VertxKafkaClientExamples;
0 7 1 vertx Lio/vertx/core/Vertx;
1 7 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
vertx
public void createProducerJava(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: new java.util.Properties
dup
invokespecial java.util.Properties.<init>:()V
astore 2
start local 2 1: aload 2
ldc "bootstrap.servers"
ldc "localhost:9092"
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ldc "acks"
ldc "1"
invokevirtual java.util.Properties.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 1
aload 2
ldc Ljava/lang/String;
ldc Ljava/lang/String;
invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Properties;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
pop
4: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lexamples/VertxKafkaClientExamples;
0 5 1 vertx Lio/vertx/core/Vertx;
1 5 2 config Ljava/util/Properties;
MethodParameters:
Name Flags
vertx
public void exampleSubscribe(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$0(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
1: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 2: aload 2
ldc "topic1"
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
3: aload 2
ldc "topic2"
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
4: aload 2
ldc "topic3"
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
5: aload 1
aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/Set;)Lio/vertx/core/Future;
pop
6: ldc "topic\\d"
invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
astore 3
start local 3 7: aload 1
aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/regex/Pattern;)Lio/vertx/core/Future;
pop
8: aload 1
ldc "a-single-topic"
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
pop
9: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lexamples/VertxKafkaClientExamples;
0 10 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
2 10 2 topics Ljava/util/Set<Ljava/lang/String;>;
7 10 3 pattern Ljava/util/regex/Pattern;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleSubscribeWithResult(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$1(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
1: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 2: aload 2
ldc "topic1"
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
3: aload 2
ldc "topic2"
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
4: aload 2
ldc "topic3"
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
5: aload 1
6: aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/util/Set;)Lio/vertx/core/Future;
7: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$2(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
8: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$3(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
9: aload 1
10: ldc "a-single-topic"
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
11: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$4(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
12: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$5(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
13: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lexamples/VertxKafkaClientExamples;
0 14 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
2 14 2 topics Ljava/util/Set<Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerPartitionsNotifs(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$6(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
1: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$7(Ljava/util/Set;)V (6)
(Ljava/util/Set;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsAssignedHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
2: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$8(Ljava/util/Set;)V (6)
(Ljava/util/Set;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsRevokedHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
3: aload 1
4: ldc "test"
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
5: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$9(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
6: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$10(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleUnsubscribe(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe:()Lio/vertx/core/Future;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxKafkaClientExamples;
0 2 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleUnsubscribeWithCallback(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
1: invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.unsubscribe:()Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$11(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/VertxKafkaClientExamples;
0 4 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerAssignPartition(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$12(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
1: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 2: aload 2
new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
3: ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
4: iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
5: invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
6: aload 1
7: aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.assign:(Ljava/util/Set;)Lio/vertx/core/Future;
8: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$13(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
9: aload 1
invokedynamic apply(Lio/vertx/kafka/client/consumer/KafkaConsumer;)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;
examples/VertxKafkaClientExamples.lambda$14(Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)Lio/vertx/core/Future; (6)
(Ljava/lang/Void;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Future.compose:(Ljava/util/function/Function;)Lio/vertx/core/Future;
10: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$15(Ljava/util/Set;)V (6)
(Ljava/util/Set;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
11: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lexamples/VertxKafkaClientExamples;
0 12 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
2 12 2 topicPartitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerPartitionsFor(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
1: ldc "test"
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.partitionsFor:(Ljava/lang/String;)Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$16(Ljava/util/List;)V (6)
(Ljava/util/List;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/VertxKafkaClientExamples;
0 4 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerListTopics(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
1: invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.listTopics:()Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$17(Ljava/util/Map;)V (6)
(Ljava/util/Map;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/VertxKafkaClientExamples;
0 4 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerWithPoll(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
1: ldc "test"
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.subscribe:(Ljava/lang/String;)Lio/vertx/core/Future;
2: aload 1
aload 2
invokedynamic handle(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$19(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/VertxKafkaClientExamples;
0 4 1 vertx Lio/vertx/core/Vertx;
0 4 2 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
vertx
consumer
public void exampleProducerPartitionsFor(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
1: ldc "test"
invokeinterface io.vertx.kafka.client.producer.KafkaProducer.partitionsFor:(Ljava/lang/String;)Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$23(Ljava/util/List;)V (6)
(Ljava/util/List;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lexamples/VertxKafkaClientExamples;
0 4 1 producer Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
producer
public void exampleConsumerManualOffsetCommit(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.commit:()Lio/vertx/core/Future;
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$25(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxKafkaClientExamples;
0 2 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleSeek(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
1: ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
2: iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
3: astore 2
start local 2 4: aload 1
5: aload 2
ldc 10
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seek:(Lio/vertx/kafka/client/common/TopicPartition;J)Lio/vertx/core/Future;
6: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$26(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
4 8 2 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleSeekToBeginning(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
1: ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
2: iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
3: astore 2
start local 2 4: aload 1
5: aload 2
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seekToBeginning:(Ljava/util/Set;)Lio/vertx/core/Future;
6: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$27(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
4 8 2 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleSeekToEnd(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
1: ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
2: iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
3: astore 2
start local 2 4: aload 1
5: aload 2
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.seekToEnd:(Ljava/util/Set;)Lio/vertx/core/Future;
6: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$28(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
4 8 2 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerBeginningOffsets(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 1: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
astore 3
start local 3 2: aload 2
aload 3
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
3: aload 1
4: aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets:(Ljava/util/Set;)Lio/vertx/core/Future;
5: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$29(Ljava/util/Map;)V (6)
(Ljava/util/Map;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
6: aload 1
7: aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.beginningOffsets:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
8: aload 3
invokedynamic handle(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$31(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
9: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lexamples/VertxKafkaClientExamples;
0 10 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
1 10 2 topicPartitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
2 10 3 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerEndOffsets(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 1: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
astore 3
start local 3 2: aload 2
aload 3
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
3: aload 1
aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets:(Ljava/util/Set;)Lio/vertx/core/Future;
4: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$32(Ljava/util/Map;)V (6)
(Ljava/util/Map;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
5: aload 1
6: aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.endOffsets:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
7: aload 3
invokedynamic handle(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$34(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
8: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lexamples/VertxKafkaClientExamples;
0 9 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
1 9 2 topicPartitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
2 9 3 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerOffsetsForTimes(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 1: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
astore 3
start local 3 2: invokestatic java.lang.System.currentTimeMillis:()J
ldc 60000
lsub
lstore 4
start local 4 3: aload 2
aload 3
lload 4
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 1
5: aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes:(Ljava/util/Map;)Lio/vertx/core/Future;
6: lload 4
invokedynamic handle(J)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$35(JLjava/util/Map;)V (6)
(Ljava/util/Map;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: aload 1
aload 3
lload 4
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.offsetsForTimes:(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)Lio/vertx/core/Future;
aload 3
lload 4
invokedynamic handle(Lio/vertx/kafka/client/common/TopicPartition;J)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$37(Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V (6)
(Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
8: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lexamples/VertxKafkaClientExamples;
0 9 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
1 9 2 topicPartitionsWithTimestamps Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;
2 9 3 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
3 9 4 timestamp J
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleConsumerFlowControl(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.kafka.client.common.TopicPartition
dup
invokespecial io.vertx.kafka.client.common.TopicPartition.<init>:()V
1: ldc "test"
invokevirtual io.vertx.kafka.client.common.TopicPartition.setTopic:(Ljava/lang/String;)Lio/vertx/kafka/client/common/TopicPartition;
2: iconst_0
invokevirtual io.vertx.kafka.client.common.TopicPartition.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartition;
3: astore 3
start local 3 4: aload 2
aload 2
aload 3
aload 1
invokedynamic handle(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Vertx;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$38(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V (6)
(Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.handler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
5: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lexamples/VertxKafkaClientExamples;
0 6 1 vertx Lio/vertx/core/Vertx;
0 6 2 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
4 6 3 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
Signature: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
vertx
consumer
public void exampleConsumerClose(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
1: invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.close:()Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$42(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
3: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$43(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lexamples/VertxKafkaClientExamples;
0 5 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleProducerWrite(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: goto 6
2: StackMap locals: int
StackMap stack:
ldc "test"
new java.lang.StringBuilder
dup
ldc "message_"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
3: astore 3
start local 3 4: aload 1
aload 3
invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
pop
end local 3 5: iinc 2 1
StackMap locals:
StackMap stack:
6: iload 2
iconst_5
if_icmplt 2
end local 2 7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 producer Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
1 7 2 i I
4 5 3 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
producer
public void exampleProducerWriteWithAck(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: goto 6
2: StackMap locals: int
StackMap stack:
ldc "test"
new java.lang.StringBuilder
dup
ldc "message_"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
3: astore 3
start local 3 4: aload 1
aload 3
invokeinterface io.vertx.kafka.client.producer.KafkaProducer.send:(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Future;
aload 3
invokedynamic handle(Lio/vertx/kafka/client/producer/KafkaProducerRecord;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$44(Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/kafka/client/producer/RecordMetadata;)V (6)
(Lio/vertx/kafka/client/producer/RecordMetadata;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
end local 3 5: iinc 2 1
StackMap locals:
StackMap stack:
6: iload 2
iconst_5
if_icmplt 2
end local 2 7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 producer Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
1 7 2 i I
4 5 3 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
producer
public void exampleProducerWriteWithSpecificPartition(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: goto 6
2: StackMap locals: int
StackMap stack:
ldc "test"
aconst_null
new java.lang.StringBuilder
dup
ldc "message_"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Integer;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
3: astore 3
start local 3 4: aload 1
aload 3
invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
pop
end local 3 5: iinc 2 1
StackMap locals:
StackMap stack:
6: iload 2
bipush 10
if_icmplt 2
end local 2 7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lexamples/VertxKafkaClientExamples;
0 8 1 producer Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
1 7 2 i I
4 5 3 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
producer
public void exampleProducerWriteWithSpecificKey(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: iconst_0
istore 2
start local 2 1: goto 7
2: StackMap locals: int
StackMap stack:
iload 2
iconst_2
irem
istore 3
start local 3 3: ldc "test"
iload 3
invokestatic java.lang.String.valueOf:(I)Ljava/lang/String;
new java.lang.StringBuilder
dup
ldc "message_"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic io.vertx.kafka.client.producer.KafkaProducerRecord.create:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)Lio/vertx/kafka/client/producer/KafkaProducerRecord;
4: astore 4
start local 4 5: aload 1
aload 4
invokeinterface io.vertx.kafka.client.producer.KafkaProducer.write:(Ljava/lang/Object;)Lio/vertx/core/Future;
pop
end local 4 end local 3 6: iinc 2 1
StackMap locals:
StackMap stack:
7: iload 2
bipush 10
if_icmplt 2
end local 2 8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lexamples/VertxKafkaClientExamples;
0 9 1 producer Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
1 8 2 i I
3 6 3 key I
5 6 4 record Lio/vertx/kafka/client/producer/KafkaProducerRecord<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
producer
public void exampleSharedProducer(io.vertx.core.Vertx, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/core/Vertx;Ljava/util/Map;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 1
ldc "the-producer"
aload 2
invokestatic io.vertx.kafka.client.producer.KafkaProducer.createShared:(Lio/vertx/core/Vertx;Ljava/lang/String;Ljava/util/Map;)Lio/vertx/kafka/client/producer/KafkaProducer;
astore 3
start local 3 1: aload 3
invokeinterface io.vertx.kafka.client.producer.KafkaProducer.close:()Lio/vertx/core/Future;
pop
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lexamples/VertxKafkaClientExamples;
0 3 1 vertx Lio/vertx/core/Vertx;
0 3 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
1 3 3 producer1 Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/core/Vertx;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
vertx
config
public void exampleProducerClose(io.vertx.kafka.client.producer.KafkaProducer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
1: invokeinterface io.vertx.kafka.client.producer.KafkaProducer.close:()Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$45(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
3: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$46(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lexamples/VertxKafkaClientExamples;
0 5 1 producer Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/producer/KafkaProducer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
producer
public void exampleErrorHandling(io.vertx.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.String>);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$47(Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lexamples/VertxKafkaClientExamples;
0 2 1 consumer Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Lio/vertx/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
consumer
public void exampleUsingVertxDeserializers();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
start local 1 1: aload 1
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 1
ldc "key.deserializer"
ldc "io.vertx.kafka.client.serialization.BufferDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 1
ldc "value.deserializer"
ldc "io.vertx.kafka.client.serialization.BufferDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 1
ldc "group.id"
ldc "my_group"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 1
ldc "auto.offset.reset"
ldc "earliest"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 1
ldc "enable.auto.commit"
ldc "false"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
8: aload 1
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
9: aload 1
ldc "key.deserializer"
ldc "io.vertx.kafka.client.serialization.JsonObjectDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
10: aload 1
ldc "value.deserializer"
ldc "io.vertx.kafka.client.serialization.JsonObjectDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
11: aload 1
ldc "group.id"
ldc "my_group"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
12: aload 1
ldc "auto.offset.reset"
ldc "earliest"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
13: aload 1
ldc "enable.auto.commit"
ldc "false"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
14: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
15: aload 1
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
16: aload 1
ldc "key.deserializer"
ldc "io.vertx.kafka.client.serialization.JsonArrayDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
17: aload 1
ldc "value.deserializer"
ldc "io.vertx.kafka.client.serialization.JsonArrayDeserializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
18: aload 1
ldc "group.id"
ldc "my_group"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
19: aload 1
ldc "auto.offset.reset"
ldc "earliest"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
20: aload 1
ldc "enable.auto.commit"
ldc "false"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
21: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 22 0 this Lexamples/VertxKafkaClientExamples;
1 22 1 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public void exampleUsingVertxSerializers();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
start local 1 1: aload 1
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 1
ldc "key.serializer"
ldc "io.vertx.kafka.client.serialization.BufferSerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 1
ldc "value.serializer"
ldc "io.vertx.kafka.client.serialization.BufferSerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 1
ldc "acks"
ldc "1"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
6: aload 1
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 1
ldc "key.serializer"
ldc "io.vertx.kafka.client.serialization.JsonObjectSerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: aload 1
ldc "value.serializer"
ldc "io.vertx.kafka.client.serialization.JsonObjectSerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
9: aload 1
ldc "acks"
ldc "1"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
10: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
11: aload 1
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
12: aload 1
ldc "key.serializer"
ldc "io.vertx.kafka.client.serialization.JsonArraySerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
13: aload 1
ldc "value.serializer"
ldc "io.vertx.kafka.client.serialization.JsonArraySerializer"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
14: aload 1
ldc "acks"
ldc "1"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
15: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lexamples/VertxKafkaClientExamples;
1 16 1 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
public void exampleUsingVertxDeserializers2(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 1: aload 2
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ldc "group.id"
ldc "my_group"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 2
ldc "auto.offset.reset"
ldc "earliest"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 2
ldc "enable.auto.commit"
ldc "false"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 1
aload 2
ldc Lio/vertx/core/buffer/Buffer;
ldc Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
6: aload 1
aload 2
ldc Lio/vertx/core/json/JsonObject;
ldc Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
7: aload 1
aload 2
ldc Lio/vertx/core/json/JsonArray;
ldc Lio/vertx/core/json/JsonArray;
invokestatic io.vertx.kafka.client.consumer.KafkaConsumer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/consumer/KafkaConsumer;
pop
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lexamples/VertxKafkaClientExamples;
0 9 1 vertx Lio/vertx/core/Vertx;
1 9 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
vertx
public void exampleUsingVertxSerializers2(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 2
start local 2 1: aload 2
ldc "bootstrap.servers"
ldc "localhost:9092"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
ldc "acks"
ldc "1"
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 1
aload 2
ldc Lio/vertx/core/buffer/Buffer;
ldc Lio/vertx/core/buffer/Buffer;
invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
pop
4: aload 1
aload 2
ldc Lio/vertx/core/json/JsonObject;
ldc Lio/vertx/core/json/JsonObject;
invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
pop
5: aload 1
aload 2
ldc Lio/vertx/core/json/JsonArray;
ldc Lio/vertx/core/json/JsonArray;
invokestatic io.vertx.kafka.client.producer.KafkaProducer.create:(Lio/vertx/core/Vertx;Ljava/util/Map;Ljava/lang/Class;Ljava/lang/Class;)Lio/vertx/kafka/client/producer/KafkaProducer;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lexamples/VertxKafkaClientExamples;
0 7 1 vertx Lio/vertx/core/Vertx;
1 7 2 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
vertx
private static void lambda$0(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Processing key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",value="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
1: ldc ",partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ",offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
2: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 record Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$1(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Processing key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",value="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
1: ldc ",partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ",offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
2: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 record Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$2(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "subscribed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$3(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Could not subscribe "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cause Ljava/lang/Throwable;
private static void lambda$4(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "subscribed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$5(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Could not subscribe "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cause Ljava/lang/Throwable;
private static void lambda$6(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Processing key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",value="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
1: ldc ",partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ",offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
2: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 record Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$7(java.util.Set);
descriptor: (Ljava/util/Set;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Partitions assigned"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 0
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 2
goto 4
StackMap locals: java.util.Set top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.kafka.client.common.TopicPartition
astore 1
start local 1 3: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
aload 1
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 1 4: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 topicPartitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
3 4 1 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
private static void lambda$8(java.util.Set);
descriptor: (Ljava/util/Set;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Partitions revoked"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 0
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 2
goto 4
StackMap locals: java.util.Set top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.kafka.client.common.TopicPartition
astore 1
start local 1 3: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
aload 1
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 1 4: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 topicPartitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
3 4 1 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
private static void lambda$9(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "subscribed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$10(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Could not subscribe "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cause Ljava/lang/Throwable;
private static void lambda$11(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Consumer unsubscribed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$12(io.vertx.kafka.client.consumer.KafkaConsumerRecord);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",value="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
1: ldc ",partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ",offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
2: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 record Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$13(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Partition assigned"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static io.vertx.core.Future lambda$14(io.vertx.kafka.client.consumer.KafkaConsumer, java.lang.Void);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)Lio/vertx/core/Future;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 1 0: aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.assignment:()Lio/vertx/core/Future;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 v Ljava/lang/Void;
private static void lambda$15(java.util.Set);
descriptor: (Ljava/util/Set;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 2
goto 3
StackMap locals: java.util.Set top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.kafka.client.common.TopicPartition
astore 1
start local 1 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
aload 1
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 1 3: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 partitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
2 3 1 topicPartition Lio/vertx/kafka/client/common/TopicPartition;
private static void lambda$16(java.util.List);
descriptor: (Ljava/util/List;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 2
goto 3
StackMap locals: java.util.List top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.vertx.kafka.client.common.PartitionInfo
astore 1
start local 1 2: getstatic java.lang.System.out:Ljava/io/PrintStream;
aload 1
invokevirtual java.io.PrintStream.println:(Ljava/lang/Object;)V
end local 1 3: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 partitions Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;
2 3 1 partitionInfo Lio/vertx/kafka/client/common/PartitionInfo;
private static void lambda$17(java.util.Map);
descriptor: (Ljava/util/Map;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokedynamic accept()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
examples/VertxKafkaClientExamples.lambda$18(Ljava/lang/String;Ljava/util/List;)V (6)
(Ljava/lang/String;Ljava/util/List;)V
invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 partitionsTopicMap Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;>;
private static void lambda$19(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer, java.lang.Void);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
start local 2 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Consumer subscribed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 0
ldc 1000
aload 1
aload 0
invokedynamic handle(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/Vertx;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$20(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/Vertx;Ljava/lang/Long;)V (6)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
pop2
2: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 v Ljava/lang/Void;
private static void lambda$23(java.util.List);
descriptor: (Ljava/util/List;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getstatic java.lang.System.out:Ljava/io/PrintStream;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Ljava/io/PrintStream;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
java/io/PrintStream.println(Ljava/lang/Object;)V (5)
(Lio/vertx/kafka/client/common/PartitionInfo;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 partitions Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;
private static void lambda$25(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Last read message offset committed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$26(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Seeking done"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$27(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Seeking done"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$28(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Seeking done"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$29(java.util.Map);
descriptor: (Ljava/util/Map;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokedynamic accept()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
examples/VertxKafkaClientExamples.lambda$30(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 results Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;
private static void lambda$31(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "Beginning offset for topic="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", beginningOffset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 6 1 beginningOffset Ljava/lang/Long;
private static void lambda$32(java.util.Map);
descriptor: (Ljava/util/Map;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokedynamic accept()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
examples/VertxKafkaClientExamples.lambda$33(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
(Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 results Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;>;
private static void lambda$34(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "End offset for topic="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", endOffset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 6 1 endOffset Ljava/lang/Long;
private static void lambda$35(long, java.util.Map);
descriptor: (JLjava/util/Map;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 2 0: aload 2
lload 0
invokedynamic accept(J)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
examples/VertxKafkaClientExamples.lambda$36(JLio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V (6)
(Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
invokeinterface java.util.Map.forEach:(Ljava/util/function/BiConsumer;)V
1: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 2 2 results Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;>;
private static void lambda$37(io.vertx.kafka.client.common.TopicPartition, long, io.vertx.kafka.client.consumer.OffsetAndTimestamp);
descriptor: (Lio/vertx/kafka/client/common/TopicPartition;JLio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 3 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "Offset for topic="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
3: ldc ", timestamp="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
lload 1
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc ", offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getOffset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
4: ldc ", offsetTimestamp="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getTimestamp:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
5: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
6: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 8 3 offsetAndTimestamp Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;
private static void lambda$38(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumerRecord);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=4
start local 3 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",value="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
1: ldc ",partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ",offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
2: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
3: aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
ifne 7
aload 3
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
ldc 5
lcmp
ifne 7
4: aload 0
aload 1
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.pause:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
5: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$39(Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
6: aload 2
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$40(Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
7: StackMap locals:
StackMap stack:
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 8 3 record Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$42(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Consumer is now closed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$43(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Close failed: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cause Ljava/lang/Throwable;
private static void lambda$44(io.vertx.kafka.client.producer.KafkaProducerRecord, io.vertx.kafka.client.producer.RecordMetadata);
descriptor: (Lio/vertx/kafka/client/producer/KafkaProducerRecord;Lio/vertx/kafka/client/producer/RecordMetadata;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "Message "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokeinterface io.vertx.kafka.client.producer.KafkaProducerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " written on topic="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
3: ldc ", offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual io.vertx.kafka.client.producer.RecordMetadata.getOffset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
4: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
5: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
6: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 7 1 recordMetadata Lio/vertx/kafka/client/producer/RecordMetadata;
private static void lambda$45(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Producer is now closed"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$46(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Close failed: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cause Ljava/lang/Throwable;
private static void lambda$47(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Error = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 e Ljava/lang/Throwable;
private static void lambda$18(java.lang.String, java.util.List);
descriptor: (Ljava/lang/String;Ljava/util/List;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "topic = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "partitions = "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 topic Ljava/lang/String;
0 3 1 partitions Ljava/util/List<Lio/vertx/kafka/client/common/PartitionInfo;>;
private static void lambda$20(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.core.Vertx, java.lang.Long);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/core/Vertx;Ljava/lang/Long;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 0
1: ldc 100
invokestatic java.time.Duration.ofMillis:(J)Ljava/time/Duration;
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.poll:(Ljava/time/Duration;)Lio/vertx/core/Future;
2: invokedynamic handle()Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$21(Lio/vertx/kafka/client/consumer/KafkaConsumerRecords;)V (6)
(Lio/vertx/kafka/client/consumer/KafkaConsumerRecords;)V
invokeinterface io.vertx.core.Future.onSuccess:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
3: aload 1
aload 2
invokedynamic handle(Lio/vertx/core/Vertx;Ljava/lang/Long;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$22(Lio/vertx/core/Vertx;Ljava/lang/Long;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.Future.onFailure:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
4: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 5 2 timerId Ljava/lang/Long;
private static void lambda$30(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "Beginning offset for topic="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", beginningOffset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 topic Lio/vertx/kafka/client/common/TopicPartition;
0 6 1 beginningOffset Ljava/lang/Long;
private static void lambda$33(io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
descriptor: (Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "End offset for topic="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: aload 0
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ", beginningOffset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 topic Lio/vertx/kafka/client/common/TopicPartition;
0 6 1 beginningOffset Ljava/lang/Long;
private static void lambda$36(long, io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndTimestamp);
descriptor: (JLio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 2 start local 3 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "Offset for topic="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual io.vertx.kafka.client.common.TopicPartition.getTopic:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: ldc ", partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokevirtual io.vertx.kafka.client.common.TopicPartition.getPartition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc "\n"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
3: ldc ", timestamp="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
lload 0
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc ", offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getOffset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
4: ldc ", offsetTimestamp="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual io.vertx.kafka.client.consumer.OffsetAndTimestamp.getTimestamp:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
5: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
6: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
7: return
end local 3 end local 2 LocalVariableTable:
Start End Slot Name Signature
0 8 2 topic Lio/vertx/kafka/client/common/TopicPartition;
0 8 3 offset Lio/vertx/kafka/client/consumer/OffsetAndTimestamp;
private static void lambda$39(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
ldc "Paused"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 v Ljava/lang/Void;
private static void lambda$40(io.vertx.core.Vertx, io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, java.lang.Void);
descriptor: (Lio/vertx/core/Vertx;Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
start local 3 0: aload 0
ldc 5000
aload 1
aload 2
invokedynamic handle(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
examples/VertxKafkaClientExamples.lambda$41(Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V (6)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
1: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 2 3 v Ljava/lang/Void;
private static void lambda$21(io.vertx.kafka.client.consumer.KafkaConsumerRecords);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumerRecords;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: iconst_0
istore 1
start local 1 1: goto 7
2: StackMap locals: int
StackMap stack:
aload 0
iload 1
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecords.recordAt:(I)Lio/vertx/kafka/client/consumer/KafkaConsumerRecord;
astore 2
start local 2 3: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.key:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ",value="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
4: ldc ",partition="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.partition:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ",offset="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 2
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecord.offset:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
5: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
end local 2 6: iinc 1 1
StackMap locals:
StackMap stack:
7: iload 1
aload 0
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumerRecords.size:()I
if_icmplt 2
end local 1 8: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 records Lio/vertx/kafka/client/consumer/KafkaConsumerRecords<Ljava/lang/String;Ljava/lang/String;>;
1 8 1 i I
3 6 2 record Lio/vertx/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$22(io.vertx.core.Vertx, java.lang.Long, java.lang.Throwable);
descriptor: (Lio/vertx/core/Vertx;Ljava/lang/Long;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 2 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Something went wrong when polling "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.Throwable.toString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
1: aload 2
invokevirtual java.lang.Throwable.printStackTrace:()V
2: aload 0
aload 1
invokevirtual java.lang.Long.longValue:()J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
3: return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 4 2 cause Ljava/lang/Throwable;
private static void lambda$41(io.vertx.kafka.client.consumer.KafkaConsumer, io.vertx.kafka.client.common.TopicPartition, java.lang.Long);
descriptor: (Lio/vertx/kafka/client/consumer/KafkaConsumer;Lio/vertx/kafka/client/common/TopicPartition;Ljava/lang/Long;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.kafka.client.consumer.KafkaConsumer.resume:(Lio/vertx/kafka/client/common/TopicPartition;)Lio/vertx/core/Future;
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 timeId Ljava/lang/Long;
}
SourceFile: "VertxKafkaClientExamples.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeInvisibleAnnotations:
io.vertx.docgen.Source()