public class io.vertx.kafka.admin.impl.KafkaAdminClientImpl implements io.vertx.kafka.admin.KafkaAdminClient
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.kafka.admin.impl.KafkaAdminClientImpl
super_class: java.lang.Object
{
private io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0002) ACC_PRIVATE
private org.apache.kafka.clients.admin.AdminClient adminClient;
descriptor: Lorg/apache/kafka/clients/admin/AdminClient;
flags: (0x0002) ACC_PRIVATE
public void <init>(io.vertx.core.Vertx, org.apache.kafka.clients.admin.AdminClient);
descriptor: (Lio/vertx/core/Vertx;Lorg/apache/kafka/clients/admin/AdminClient;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
2: aload 0
aload 2
putfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 4 1 vertx Lio/vertx/core/Vertx;
0 4 2 adminClient Lorg/apache/kafka/clients/admin/AdminClient;
MethodParameters:
Name Flags
vertx
adminClient
public void describeTopics(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.TopicDescription>>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.describeTopics:(Ljava/util/List;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 topicNames Ljava/util/List<Ljava/lang/String;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/TopicDescription;>;>;>;
Signature: (Ljava/util/List<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/TopicDescription;>;>;>;)V
MethodParameters:
Name Flags
topicNames
completionHandler
public io.vertx.core.Future<java.util.Map<java.lang.String, io.vertx.kafka.admin.TopicDescription>> describeTopics(java.util.List<java.lang.String>);
descriptor: (Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokevirtual org.apache.kafka.clients.admin.AdminClient.describeTopics:(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeTopicsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.DescribeTopicsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$0(Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V (6)
(Ljava/util/Map;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 topicNames Ljava/util/List<Ljava/lang/String;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/TopicDescription;>;>;
3 5 4 describeTopicsResult Lorg/apache/kafka/clients/admin/DescribeTopicsResult;
Signature: (Ljava/util/List<Ljava/lang/String;>;)Lio/vertx/core/Future<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/TopicDescription;>;>;
MethodParameters:
Name Flags
topicNames
public void listTopics(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<java.lang.String>>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.listTopics:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.onComplete:(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 Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Ljava/lang/String;>;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<Ljava/lang/String;>;>;>;)V
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.Future<java.util.Set<java.lang.String>> listTopics();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 1
start local 1 1: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
invokevirtual org.apache.kafka.clients.admin.AdminClient.listTopics:()Lorg/apache/kafka/clients/admin/ListTopicsResult;
astore 3
start local 3 3: aload 3
invokevirtual org.apache.kafka.clients.admin.ListTopicsResult.names:()Lorg/apache/kafka/common/KafkaFuture;
aload 2
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$3(Lio/vertx/core/Promise;Ljava/util/Set;Ljava/lang/Throwable;)V (6)
(Ljava/util/Set;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
1 5 1 ctx Lio/vertx/core/impl/ContextInternal;
2 5 2 promise Lio/vertx/core/Promise<Ljava/util/Set<Ljava/lang/String;>;>;
3 5 3 listTopicsResult Lorg/apache/kafka/clients/admin/ListTopicsResult;
Signature: ()Lio/vertx/core/Future<Ljava/util/Set<Ljava/lang/String;>;>;
public void createTopics(java.util.List<io.vertx.kafka.admin.NewTopic>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.createTopics:(Ljava/util/List;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 topics Ljava/util/List<Lio/vertx/kafka/admin/NewTopic;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/util/List<Lio/vertx/kafka/admin/NewTopic;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
topics
completionHandler
public io.vertx.core.Future<java.lang.Void> createTopics(java.util.List<io.vertx.kafka.admin.NewTopic>);
descriptor: (Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokestatic io.vertx.kafka.client.common.impl.Helper.toNewTopicList:(Ljava/util/List;)Ljava/util/List;
invokevirtual org.apache.kafka.clients.admin.AdminClient.createTopics:(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/CreateTopicsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.CreateTopicsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$4(Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Void;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 topics Ljava/util/List<Lio/vertx/kafka/admin/NewTopic;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
3 5 4 createTopicsResult Lorg/apache/kafka/clients/admin/CreateTopicsResult;
Signature: (Ljava/util/List<Lio/vertx/kafka/admin/NewTopic;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
topics
public void deleteTopics(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.deleteTopics:(Ljava/util/List;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 topicNames Ljava/util/List<Ljava/lang/String;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/util/List<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
topicNames
completionHandler
public io.vertx.core.Future<java.lang.Void> deleteTopics(java.util.List<java.lang.String>);
descriptor: (Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokevirtual org.apache.kafka.clients.admin.AdminClient.deleteTopics:(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DeleteTopicsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.DeleteTopicsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$5(Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Void;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 topicNames Ljava/util/List<Ljava/lang/String;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
3 5 4 deleteTopicsResult Lorg/apache/kafka/clients/admin/DeleteTopicsResult;
Signature: (Ljava/util/List<Ljava/lang/String;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
topicNames
public void describeConfigs(java.util.List<io.vertx.kafka.client.common.ConfigResource>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.ConfigResource, io.vertx.kafka.admin.Config>>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.describeConfigs:(Ljava/util/List;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 configResources Ljava/util/List<Lio/vertx/kafka/client/common/ConfigResource;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;>;>;
Signature: (Ljava/util/List<Lio/vertx/kafka/client/common/ConfigResource;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;>;>;)V
MethodParameters:
Name Flags
configResources
completionHandler
public io.vertx.core.Future<java.util.Map<io.vertx.kafka.client.common.ConfigResource, io.vertx.kafka.admin.Config>> describeConfigs(java.util.List<io.vertx.kafka.client.common.ConfigResource>);
descriptor: (Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokestatic io.vertx.kafka.client.common.impl.Helper.toConfigResourceList:(Ljava/util/List;)Ljava/util/List;
invokevirtual org.apache.kafka.clients.admin.AdminClient.describeConfigs:(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeConfigsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.DescribeConfigsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$6(Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V (6)
(Ljava/util/Map;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 configResources Ljava/util/List<Lio/vertx/kafka/client/common/ConfigResource;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;>;
3 5 4 describeConfigsResult Lorg/apache/kafka/clients/admin/DescribeConfigsResult;
Signature: (Ljava/util/List<Lio/vertx/kafka/client/common/ConfigResource;>;)Lio/vertx/core/Future<Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;>;
MethodParameters:
Name Flags
configResources
public void alterConfigs(java.util.Map<io.vertx.kafka.client.common.ConfigResource, io.vertx.kafka.admin.Config>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.alterConfigs:(Ljava/util/Map;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 configs Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
configs
completionHandler
public io.vertx.core.Future<java.lang.Void> alterConfigs(java.util.Map<io.vertx.kafka.client.common.ConfigResource, io.vertx.kafka.admin.Config>);
descriptor: (Ljava/util/Map;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokestatic io.vertx.kafka.client.common.impl.Helper.toConfigMaps:(Ljava/util/Map;)Ljava/util/Map;
invokevirtual org.apache.kafka.clients.admin.AdminClient.alterConfigs:(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/AlterConfigsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.AlterConfigsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$7(Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Void;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 configs Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
3 5 4 alterConfigsResult Lorg/apache/kafka/clients/admin/AlterConfigsResult;
Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
configs
public void listConsumerGroups(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<io.vertx.kafka.admin.ConsumerGroupListing>>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.listConsumerGroups:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.onComplete:(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 Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/admin/ConsumerGroupListing;>;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/kafka/admin/ConsumerGroupListing;>;>;>;)V
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.Future<java.util.List<io.vertx.kafka.admin.ConsumerGroupListing>> listConsumerGroups();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 1
start local 1 1: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
invokevirtual org.apache.kafka.clients.admin.AdminClient.listConsumerGroups:()Lorg/apache/kafka/clients/admin/ListConsumerGroupsResult;
astore 3
start local 3 3: aload 3
invokevirtual org.apache.kafka.clients.admin.ListConsumerGroupsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 2
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$8(Lio/vertx/core/Promise;Ljava/util/Collection;Ljava/lang/Throwable;)V (6)
(Ljava/util/Collection;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
1 5 1 ctx Lio/vertx/core/impl/ContextInternal;
2 5 2 promise Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/kafka/admin/ConsumerGroupListing;>;>;
3 5 3 listConsumerGroupsResult Lorg/apache/kafka/clients/admin/ListConsumerGroupsResult;
Signature: ()Lio/vertx/core/Future<Ljava/util/List<Lio/vertx/kafka/admin/ConsumerGroupListing;>;>;
public void describeConsumerGroups(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.ConsumerGroupDescription>>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.describeConsumerGroups:(Ljava/util/List;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 groupIds Ljava/util/List<Ljava/lang/String;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/ConsumerGroupDescription;>;>;>;
Signature: (Ljava/util/List<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/ConsumerGroupDescription;>;>;>;)V
MethodParameters:
Name Flags
groupIds
completionHandler
public io.vertx.core.Future<java.util.Map<java.lang.String, io.vertx.kafka.admin.ConsumerGroupDescription>> describeConsumerGroups(java.util.List<java.lang.String>);
descriptor: (Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokevirtual org.apache.kafka.clients.admin.AdminClient.describeConsumerGroups:(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DescribeConsumerGroupsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.DescribeConsumerGroupsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$9(Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V (6)
(Ljava/util/Map;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 groupIds Ljava/util/List<Ljava/lang/String;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/ConsumerGroupDescription;>;>;
3 5 4 describeConsumerGroupsResult Lorg/apache/kafka/clients/admin/DescribeConsumerGroupsResult;
Signature: (Ljava/util/List<Ljava/lang/String;>;)Lio/vertx/core/Future<Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/ConsumerGroupDescription;>;>;
MethodParameters:
Name Flags
groupIds
public void listConsumerGroupOffsets(java.lang.String, io.vertx.kafka.admin.ListConsumerGroupOffsetsOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndMetadata>>>);
descriptor: (Ljava/lang/String;Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.listConsumerGroupOffsets:(Ljava/lang/String;Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;)Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 groupId Ljava/lang/String;
0 2 2 options Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;
0 2 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;>;>;
Signature: (Ljava/lang/String;Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;>;>;)V
MethodParameters:
Name Flags
groupId
options
completionHandler
public io.vertx.core.Future<java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.client.consumer.OffsetAndMetadata>> listConsumerGroupOffsets(java.lang.String, io.vertx.kafka.admin.ListConsumerGroupOffsetsOptions);
descriptor: (Ljava/lang/String;Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 3
start local 3 1: aload 3
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
aload 2
invokestatic io.vertx.kafka.client.common.impl.Helper.to:(Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;)Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions;
invokevirtual org.apache.kafka.clients.admin.AdminClient.listConsumerGroupOffsets:(Ljava/lang/String;Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions;)Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult;
astore 5
start local 5 3: aload 5
invokevirtual org.apache.kafka.clients.admin.ListConsumerGroupOffsetsResult.partitionsToOffsetAndMetadata:()Lorg/apache/kafka/common/KafkaFuture;
aload 4
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$10(Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V (6)
(Ljava/util/Map;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 groupId Ljava/lang/String;
0 5 2 options Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;
1 5 3 ctx Lio/vertx/core/impl/ContextInternal;
2 5 4 promise Lio/vertx/core/Promise<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;>;
3 5 5 listConsumerGroupOffsetsResult Lorg/apache/kafka/clients/admin/ListConsumerGroupOffsetsResult;
Signature: (Ljava/lang/String;Lio/vertx/kafka/admin/ListConsumerGroupOffsetsOptions;)Lio/vertx/core/Future<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;>;
MethodParameters:
Name Flags
groupId
options
public void deleteConsumerGroups(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/util/List;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.deleteConsumerGroups:(Ljava/util/List;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 groupIds Ljava/util/List<Ljava/lang/String;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/util/List<Ljava/lang/String;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
groupIds
completionHandler
public io.vertx.core.Future<java.lang.Void> deleteConsumerGroups(java.util.List<java.lang.String>);
descriptor: (Ljava/util/List;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokevirtual org.apache.kafka.clients.admin.AdminClient.deleteConsumerGroups:(Ljava/util/Collection;)Lorg/apache/kafka/clients/admin/DeleteConsumerGroupsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.DeleteConsumerGroupsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$11(Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Void;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 groupIds Ljava/util/List<Ljava/lang/String;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
3 5 4 deleteConsumerGroupsResult Lorg/apache/kafka/clients/admin/DeleteConsumerGroupsResult;
Signature: (Ljava/util/List<Ljava/lang/String;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
groupIds
public void deleteConsumerGroupOffsets(java.lang.String, java.util.Set<io.vertx.kafka.client.common.TopicPartition>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/String;Ljava/util/Set;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.deleteConsumerGroupOffsets:(Ljava/lang/String;Ljava/util/Set;)Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 groupId Ljava/lang/String;
0 2 2 partitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
0 2 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/lang/String;Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
groupId
partitions
completionHandler
public io.vertx.core.Future<java.lang.Void> deleteConsumerGroupOffsets(java.lang.String, java.util.Set<io.vertx.kafka.client.common.TopicPartition>);
descriptor: (Ljava/lang/String;Ljava/util/Set;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 3
start local 3 1: aload 3
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
aload 2
invokestatic io.vertx.kafka.client.common.impl.Helper.toTopicPartitionSet:(Ljava/util/Set;)Ljava/util/Set;
invokevirtual org.apache.kafka.clients.admin.AdminClient.deleteConsumerGroupOffsets:(Ljava/lang/String;Ljava/util/Set;)Lorg/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult;
astore 5
start local 5 3: aload 5
invokevirtual org.apache.kafka.clients.admin.DeleteConsumerGroupOffsetsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 4
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$12(Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Void;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 groupId Ljava/lang/String;
0 5 2 partitions Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;
1 5 3 ctx Lio/vertx/core/impl/ContextInternal;
2 5 4 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
3 5 5 deleteConsumerGroupOffsetsResult Lorg/apache/kafka/clients/admin/DeleteConsumerGroupOffsetsResult;
Signature: (Ljava/lang/String;Ljava/util/Set<Lio/vertx/kafka/client/common/TopicPartition;>;)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
groupId
partitions
public void describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.describeCluster:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.onComplete:(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 Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/admin/ClusterDescription;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/kafka/admin/ClusterDescription;>;>;)V
MethodParameters:
Name Flags
completionHandler
public io.vertx.core.Future<io.vertx.kafka.admin.ClusterDescription> describeCluster();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 1
start local 1 1: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 2
start local 2 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
invokevirtual org.apache.kafka.clients.admin.AdminClient.describeCluster:()Lorg/apache/kafka/clients/admin/DescribeClusterResult;
astore 3
start local 3 3: iconst_3
anewarray org.apache.kafka.common.KafkaFuture
dup
iconst_0
aload 3
invokevirtual org.apache.kafka.clients.admin.DescribeClusterResult.clusterId:()Lorg/apache/kafka/common/KafkaFuture;
aastore
dup
iconst_1
aload 3
invokevirtual org.apache.kafka.clients.admin.DescribeClusterResult.controller:()Lorg/apache/kafka/common/KafkaFuture;
aastore
dup
iconst_2
aload 3
invokevirtual org.apache.kafka.clients.admin.DescribeClusterResult.nodes:()Lorg/apache/kafka/common/KafkaFuture;
aastore
invokestatic org.apache.kafka.common.KafkaFuture.allOf:([Lorg/apache/kafka/common/KafkaFuture;)Lorg/apache/kafka/common/KafkaFuture;
aload 3
aload 2
invokedynamic accept(Lorg/apache/kafka/clients/admin/DescribeClusterResult;Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$13(Lorg/apache/kafka/clients/admin/DescribeClusterResult;Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Void;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
1 5 1 ctx Lio/vertx/core/impl/ContextInternal;
2 5 2 promise Lio/vertx/core/Promise<Lio/vertx/kafka/admin/ClusterDescription;>;
3 5 3 describeClusterResult Lorg/apache/kafka/clients/admin/DescribeClusterResult;
Signature: ()Lio/vertx/core/Future<Lio/vertx/kafka/admin/ClusterDescription;>;
public void listOffsets(java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.admin.OffsetSpec>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.admin.ListOffsetsResultInfo>>>);
descriptor: (Ljava/util/Map;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.listOffsets:(Ljava/util/Map;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 topicPartitionOffsets Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/OffsetSpec;>;
0 2 2 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/ListOffsetsResultInfo;>;>;>;
Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/OffsetSpec;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/ListOffsetsResultInfo;>;>;>;)V
MethodParameters:
Name Flags
topicPartitionOffsets
completionHandler
public io.vertx.core.Future<java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.admin.ListOffsetsResultInfo>> listOffsets(java.util.Map<io.vertx.kafka.client.common.TopicPartition, io.vertx.kafka.admin.OffsetSpec>);
descriptor: (Ljava/util/Map;)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 3
start local 3 2: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
aload 1
invokestatic io.vertx.kafka.client.common.impl.Helper.toTopicPartitionOffsets:(Ljava/util/Map;)Ljava/util/Map;
invokevirtual org.apache.kafka.clients.admin.AdminClient.listOffsets:(Ljava/util/Map;)Lorg/apache/kafka/clients/admin/ListOffsetsResult;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.kafka.clients.admin.ListOffsetsResult.all:()Lorg/apache/kafka/common/KafkaFuture;
aload 3
invokedynamic accept(Lio/vertx/core/Promise;)Lorg/apache/kafka/common/KafkaFuture$BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$15(Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V (6)
(Ljava/util/Map;Ljava/lang/Throwable;)V
invokevirtual org.apache.kafka.common.KafkaFuture.whenComplete:(Lorg/apache/kafka/common/KafkaFuture$BiConsumer;)Lorg/apache/kafka/common/KafkaFuture;
pop
4: aload 3
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 5 1 topicPartitionOffsets Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/OffsetSpec;>;
1 5 2 ctx Lio/vertx/core/impl/ContextInternal;
2 5 3 promise Lio/vertx/core/Promise<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/ListOffsetsResultInfo;>;>;
3 5 4 listOffsetsResult Lorg/apache/kafka/clients/admin/ListOffsetsResult;
Signature: (Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/OffsetSpec;>;)Lio/vertx/core/Future<Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/ListOffsetsResultInfo;>;>;
MethodParameters:
Name Flags
topicPartitionOffsets
public io.vertx.core.Future<java.lang.Void> close();
descriptor: ()Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
lconst_0
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.close:(J)Lio/vertx/core/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;
public io.vertx.core.Future<java.lang.Void> close(long);
descriptor: (J)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
checkcast io.vertx.core.impl.ContextInternal
astore 3
start local 3 1: aload 3
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 4
start local 4 2: aload 3
aload 0
lload 1
invokedynamic handle(Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;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
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$16(JLio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
invokeinterface io.vertx.core.impl.ContextInternal.executeBlocking:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 4 1 timeout J
1 4 3 ctx Lio/vertx/core/impl/ContextInternal;
2 4 4 promise Lio/vertx/core/Promise<Ljava/lang/Void;>;
Signature: (J)Lio/vertx/core/Future<Ljava/lang/Void;>;
MethodParameters:
Name Flags
timeout
public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.close:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.onComplete:(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 Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
handler
public void close(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (JLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 3 0: aload 0
lload 1
invokevirtual io.vertx.kafka.admin.impl.KafkaAdminClientImpl.close:(J)Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
1: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 2 1 timeout J
0 2 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
timeout
handler
private static void lambda$0(io.vertx.core.Promise, java.util.Map, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=10, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 25
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 2: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 22
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 5: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.TopicDescription
invokevirtual org.apache.kafka.clients.admin.TopicDescription.partitions:()Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 8
goto 16
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map java.util.Map$Entry java.util.Iterator java.util.List top java.util.Iterator
StackMap stack:
6: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.kafka.common.TopicPartitionInfo
astore 7
start local 7 7: new io.vertx.kafka.client.common.TopicPartitionInfo
dup
invokespecial io.vertx.kafka.client.common.TopicPartitionInfo.<init>:()V
astore 9
start local 9 8: aload 9
9: aload 7
invokevirtual org.apache.kafka.common.TopicPartitionInfo.isr:()Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/common/impl/Helper.from(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node; (6)
(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
10: invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.setIsr:(Ljava/util/List;)Lio/vertx/kafka/client/common/TopicPartitionInfo;
11: aload 7
invokevirtual org.apache.kafka.common.TopicPartitionInfo.leader:()Lorg/apache/kafka/common/Node;
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.setLeader:(Lio/vertx/kafka/client/common/Node;)Lio/vertx/kafka/client/common/TopicPartitionInfo;
12: aload 7
invokevirtual org.apache.kafka.common.TopicPartitionInfo.partition:()I
invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.setPartition:(I)Lio/vertx/kafka/client/common/TopicPartitionInfo;
13: aload 7
invokevirtual org.apache.kafka.common.TopicPartitionInfo.replicas:()Ljava/util/List;
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/kafka/client/common/impl/Helper.from(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node; (6)
(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
14: invokevirtual io.vertx.kafka.client.common.TopicPartitionInfo.setReplicas:(Ljava/util/List;)Lio/vertx/kafka/client/common/TopicPartitionInfo;
pop
15: aload 6
aload 9
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 end local 7 16: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
17: new io.vertx.kafka.admin.TopicDescription
dup
invokespecial io.vertx.kafka.admin.TopicDescription.<init>:()V
astore 7
start local 7 18: aload 7
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.TopicDescription
invokevirtual org.apache.kafka.clients.admin.TopicDescription.isInternal:()Z
invokevirtual io.vertx.kafka.admin.TopicDescription.setInternal:(Z)Lio/vertx/kafka/admin/TopicDescription;
19: aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual io.vertx.kafka.admin.TopicDescription.setName:(Ljava/lang/String;)Lio/vertx/kafka/admin/TopicDescription;
20: aload 6
invokevirtual io.vertx.kafka.admin.TopicDescription.setPartitions:(Ljava/util/List;)Lio/vertx/kafka/admin/TopicDescription;
pop
21: aload 3
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 7
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 7 end local 6 end local 4 22: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
23: aload 0
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 24: goto 26
25: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
26: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 27 1 t Ljava/util/Map<Ljava/lang/String;Lorg/apache/kafka/clients/admin/TopicDescription;>;
0 27 2 ex Ljava/lang/Throwable;
2 24 3 topics Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/TopicDescription;>;
4 22 4 topicDescriptionEntry Ljava/util/Map$Entry<Ljava/lang/String;Lorg/apache/kafka/clients/admin/TopicDescription;>;
5 22 6 partitions Ljava/util/List<Lio/vertx/kafka/client/common/TopicPartitionInfo;>;
7 16 7 kafkaPartitionInfo Lorg/apache/kafka/common/TopicPartitionInfo;
8 16 9 topicPartitionInfo Lio/vertx/kafka/client/common/TopicPartitionInfo;
18 22 7 topicDescription Lio/vertx/kafka/admin/TopicDescription;
private static void lambda$3(io.vertx.core.Promise, java.util.Set, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Set;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
aload 1
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 topics Ljava/util/Set<Ljava/lang/String;>;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$4(io.vertx.core.Promise, java.lang.Void, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 v Ljava/lang/Void;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$5(io.vertx.core.Promise, java.lang.Void, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 v Ljava/lang/Void;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$6(io.vertx.core.Promise, java.util.Map, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=8, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 10
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 2: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 7
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 4: aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.kafka.common.config.ConfigResource
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/config/ConfigResource;)Lio/vertx/kafka/client/common/ConfigResource;
astore 6
start local 6 5: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.Config
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/clients/admin/Config;)Lio/vertx/kafka/admin/Config;
astore 7
start local 7 6: aload 3
aload 6
aload 7
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 7 end local 6 end local 4 7: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
8: aload 0
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 9: goto 11
10: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
11: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 12 1 m Ljava/util/Map<Lorg/apache/kafka/common/config/ConfigResource;Lorg/apache/kafka/clients/admin/Config;>;
0 12 2 ex Ljava/lang/Throwable;
2 9 3 configs Ljava/util/Map<Lio/vertx/kafka/client/common/ConfigResource;Lio/vertx/kafka/admin/Config;>;
4 7 4 configEntry Ljava/util/Map$Entry<Lorg/apache/kafka/common/config/ConfigResource;Lorg/apache/kafka/clients/admin/Config;>;
5 7 6 configResource Lio/vertx/kafka/client/common/ConfigResource;
6 7 7 config Lio/vertx/kafka/admin/Config;
private static void lambda$7(io.vertx.core.Promise, java.lang.Void, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 v Ljava/lang/Void;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$8(io.vertx.core.Promise, java.util.Collection, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Collection;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
aload 1
invokestatic io.vertx.kafka.client.common.impl.Helper.fromConsumerGroupListings:(Ljava/util/Collection;)Ljava/util/List;
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 groupIds Ljava/util/Collection<Lorg/apache/kafka/clients/admin/ConsumerGroupListing;>;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$9(io.vertx.core.Promise, java.util.Map, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=10, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 25
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 2: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 22
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 5: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ConsumerGroupDescription
invokevirtual org.apache.kafka.clients.admin.ConsumerGroupDescription.members:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 8
goto 13
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map java.util.Map$Entry java.util.Iterator java.util.List top java.util.Iterator
StackMap stack:
6: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.MemberDescription
astore 7
start local 7 7: new io.vertx.kafka.admin.MemberDescription
dup
invokespecial io.vertx.kafka.admin.MemberDescription.<init>:()V
astore 9
start local 9 8: aload 9
aload 7
invokevirtual org.apache.kafka.clients.admin.MemberDescription.consumerId:()Ljava/lang/String;
invokevirtual io.vertx.kafka.admin.MemberDescription.setConsumerId:(Ljava/lang/String;)Lio/vertx/kafka/admin/MemberDescription;
9: aload 7
invokevirtual org.apache.kafka.clients.admin.MemberDescription.clientId:()Ljava/lang/String;
invokevirtual io.vertx.kafka.admin.MemberDescription.setClientId:(Ljava/lang/String;)Lio/vertx/kafka/admin/MemberDescription;
10: aload 7
invokevirtual org.apache.kafka.clients.admin.MemberDescription.assignment:()Lorg/apache/kafka/clients/admin/MemberAssignment;
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/clients/admin/MemberAssignment;)Lio/vertx/kafka/admin/MemberAssignment;
invokevirtual io.vertx.kafka.admin.MemberDescription.setAssignment:(Lio/vertx/kafka/admin/MemberAssignment;)Lio/vertx/kafka/admin/MemberDescription;
11: aload 7
invokevirtual org.apache.kafka.clients.admin.MemberDescription.host:()Ljava/lang/String;
invokevirtual io.vertx.kafka.admin.MemberDescription.setHost:(Ljava/lang/String;)Lio/vertx/kafka/admin/MemberDescription;
pop
12: aload 6
aload 9
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 end local 7 13: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
14: new io.vertx.kafka.admin.ConsumerGroupDescription
dup
invokespecial io.vertx.kafka.admin.ConsumerGroupDescription.<init>:()V
astore 7
start local 7 15: aload 7
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ConsumerGroupDescription
invokevirtual org.apache.kafka.clients.admin.ConsumerGroupDescription.groupId:()Ljava/lang/String;
invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.setGroupId:(Ljava/lang/String;)Lio/vertx/kafka/admin/ConsumerGroupDescription;
16: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ConsumerGroupDescription
invokevirtual org.apache.kafka.clients.admin.ConsumerGroupDescription.coordinator:()Lorg/apache/kafka/common/Node;
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.setCoordinator:(Lio/vertx/kafka/client/common/Node;)Lio/vertx/kafka/admin/ConsumerGroupDescription;
17: aload 6
invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.setMembers:(Ljava/util/List;)Lio/vertx/kafka/admin/ConsumerGroupDescription;
18: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ConsumerGroupDescription
invokevirtual org.apache.kafka.clients.admin.ConsumerGroupDescription.partitionAssignor:()Ljava/lang/String;
invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.setPartitionAssignor:(Ljava/lang/String;)Lio/vertx/kafka/admin/ConsumerGroupDescription;
19: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ConsumerGroupDescription
invokevirtual org.apache.kafka.clients.admin.ConsumerGroupDescription.isSimpleConsumerGroup:()Z
invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.setSimpleConsumerGroup:(Z)Lio/vertx/kafka/admin/ConsumerGroupDescription;
20: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ConsumerGroupDescription
invokevirtual org.apache.kafka.clients.admin.ConsumerGroupDescription.state:()Lorg/apache/kafka/common/ConsumerGroupState;
invokevirtual io.vertx.kafka.admin.ConsumerGroupDescription.setState:(Lorg/apache/kafka/common/ConsumerGroupState;)Lio/vertx/kafka/admin/ConsumerGroupDescription;
pop
21: aload 3
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 7
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 7 end local 6 end local 4 22: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
23: aload 0
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 24: goto 26
25: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
26: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 27 1 cg Ljava/util/Map<Ljava/lang/String;Lorg/apache/kafka/clients/admin/ConsumerGroupDescription;>;
0 27 2 ex Ljava/lang/Throwable;
2 24 3 consumerGroups Ljava/util/Map<Ljava/lang/String;Lio/vertx/kafka/admin/ConsumerGroupDescription;>;
4 22 4 cgDescriptionEntry Ljava/util/Map$Entry<Ljava/lang/String;Lorg/apache/kafka/clients/admin/ConsumerGroupDescription;>;
5 22 6 members Ljava/util/List<Lio/vertx/kafka/admin/MemberDescription;>;
7 13 7 memberDescription Lorg/apache/kafka/clients/admin/MemberDescription;
8 13 9 m Lio/vertx/kafka/admin/MemberDescription;
15 22 7 consumerGroupDescription Lio/vertx/kafka/admin/ConsumerGroupDescription;
private static void lambda$10(io.vertx.core.Promise, java.util.Map, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=6, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 8
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 2: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 5
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 4: aload 3
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.kafka.common.TopicPartition
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/kafka/client/common/TopicPartition;
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.consumer.OffsetAndMetadata
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;)Lio/vertx/kafka/client/consumer/OffsetAndMetadata;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 4 5: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 0
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 7: goto 9
8: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
9: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 10 1 cgo Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
0 10 2 ex Ljava/lang/Throwable;
2 7 3 consumerGroupOffsets Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/client/consumer/OffsetAndMetadata;>;
4 5 4 cgoOffset Ljava/util/Map$Entry<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/consumer/OffsetAndMetadata;>;
private static void lambda$11(io.vertx.core.Promise, java.lang.Void, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 v Ljava/lang/Void;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$12(io.vertx.core.Promise, java.lang.Void, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 3
1: aload 0
invokeinterface io.vertx.core.Promise.complete:()V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 v Ljava/lang/Void;
0 5 2 ex Ljava/lang/Throwable;
private static void lambda$13(org.apache.kafka.clients.admin.DescribeClusterResult, io.vertx.core.Promise, java.lang.Void, java.lang.Throwable);
descriptor: (Lorg/apache/kafka/clients/admin/DescribeClusterResult;Lio/vertx/core/Promise;Ljava/lang/Void;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=10, args_size=4
start local 2 start local 3 0: aload 3
ifnonnull 13
1: aload 0
invokevirtual org.apache.kafka.clients.admin.DescribeClusterResult.clusterId:()Lorg/apache/kafka/common/KafkaFuture;
invokevirtual org.apache.kafka.common.KafkaFuture.get:()Ljava/lang/Object;
checkcast java.lang.String
astore 4
start local 4 2: aload 0
invokevirtual org.apache.kafka.clients.admin.DescribeClusterResult.controller:()Lorg/apache/kafka/common/KafkaFuture;
invokevirtual org.apache.kafka.common.KafkaFuture.get:()Ljava/lang/Object;
checkcast org.apache.kafka.common.Node
astore 5
start local 5 3: aload 0
invokevirtual org.apache.kafka.clients.admin.DescribeClusterResult.nodes:()Lorg/apache/kafka/common/KafkaFuture;
invokevirtual org.apache.kafka.common.KafkaFuture.get:()Ljava/lang/Object;
checkcast java.util.Collection
astore 6
start local 6 4: aload 5
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
astore 7
start local 7 5: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 8
start local 8 6: aload 6
aload 8
invokedynamic accept(Ljava/util/List;)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
io/vertx/kafka/admin/impl/KafkaAdminClientImpl.lambda$14(Ljava/util/List;Lorg/apache/kafka/common/Node;)V (6)
(Lorg/apache/kafka/common/Node;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
7: new io.vertx.kafka.admin.ClusterDescription
dup
aload 4
aload 7
aload 8
invokespecial io.vertx.kafka.admin.ClusterDescription.<init>:(Ljava/lang/String;Lio/vertx/kafka/client/common/Node;Ljava/util/List;)V
astore 9
start local 9 8: aload 1
aload 9
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 9: goto 14
StackMap locals:
StackMap stack: java.lang.Exception
10: astore 4
start local 4 11: aload 1
aload 4
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 4 12: goto 14
13: StackMap locals:
StackMap stack:
aload 1
aload 3
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
14: StackMap locals:
StackMap stack:
return
end local 3 end local 2 LocalVariableTable:
Start End Slot Name Signature
0 15 2 r Ljava/lang/Void;
0 15 3 ex Ljava/lang/Throwable;
2 9 4 clusterId Ljava/lang/String;
3 9 5 rcontroller Lorg/apache/kafka/common/Node;
4 9 6 rnodes Ljava/util/Collection<Lorg/apache/kafka/common/Node;>;
5 9 7 controller Lio/vertx/kafka/client/common/Node;
6 9 8 nodes Ljava/util/List<Lio/vertx/kafka/client/common/Node;>;
8 9 9 clusterDescription Lio/vertx/kafka/admin/ClusterDescription;
11 12 4 e Ljava/lang/Exception;
Exception table:
from to target type
1 9 10 Class java.lang.InterruptedException
1 9 10 Class java.util.concurrent.ExecutionException
private static void lambda$15(io.vertx.core.Promise, java.util.Map, java.lang.Throwable);
descriptor: (Lio/vertx/core/Promise;Ljava/util/Map;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=6, args_size=3
start local 1 start local 2 0: aload 2
ifnonnull 8
1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 2: aload 1
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 5
StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable java.util.Map top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 4: aload 3
aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.kafka.common.TopicPartition
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/TopicPartition;)Lio/vertx/kafka/client/common/TopicPartition;
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.kafka.clients.admin.ListOffsetsResult$ListOffsetsResultInfo
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/clients/admin/ListOffsetsResult$ListOffsetsResultInfo;)Lio/vertx/kafka/admin/ListOffsetsResultInfo;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 4 5: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 0
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 7: goto 9
8: StackMap locals: io.vertx.core.Promise java.util.Map java.lang.Throwable
StackMap stack:
aload 0
aload 2
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
9: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 10 1 o Ljava/util/Map<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/admin/ListOffsetsResult$ListOffsetsResultInfo;>;
0 10 2 ex Ljava/lang/Throwable;
2 7 3 listOffsets Ljava/util/Map<Lio/vertx/kafka/client/common/TopicPartition;Lio/vertx/kafka/admin/ListOffsetsResultInfo;>;
4 5 4 oOffset Ljava/util/Map$Entry<Lorg/apache/kafka/common/TopicPartition;Lorg/apache/kafka/clients/admin/ListOffsetsResult$ListOffsetsResultInfo;>;
private void lambda$16(long, io.vertx.core.Promise);
descriptor: (JLio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 3 0: lload 1
lconst_0
lcmp
ifle 3
1: aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
lload 1
invokestatic java.time.Duration.ofMillis:(J)Ljava/time/Duration;
invokevirtual org.apache.kafka.clients.admin.AdminClient.close:(Ljava/time/Duration;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.kafka.admin.impl.KafkaAdminClientImpl.adminClient:Lorg/apache/kafka/clients/admin/AdminClient;
invokevirtual org.apache.kafka.clients.admin.AdminClient.close:()V
4: StackMap locals:
StackMap stack:
aload 3
invokeinterface io.vertx.core.Promise.complete:()V
5: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/kafka/admin/impl/KafkaAdminClientImpl;
0 6 3 prom Lio/vertx/core/Promise<Ljava/lang/Object;>;
private static void lambda$14(java.util.List, org.apache.kafka.common.Node);
descriptor: (Ljava/util/List;Lorg/apache/kafka/common/Node;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokestatic io.vertx.kafka.client.common.impl.Helper.from:(Lorg/apache/kafka/common/Node;)Lio/vertx/kafka/client/common/Node;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
1: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 2 1 rnode Lorg/apache/kafka/common/Node;
}
SourceFile: "KafkaAdminClientImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map
public ListOffsetsResultInfo = org.apache.kafka.clients.admin.ListOffsetsResult$ListOffsetsResultInfo of org.apache.kafka.clients.admin.ListOffsetsResult
public abstract BiConsumer = org.apache.kafka.common.KafkaFuture$BiConsumer of org.apache.kafka.common.KafkaFuture
KafkaAdminClientImpl
vertx: Vertx
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-kafka-client: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)