public class io.vertx.kafka.client.common.KafkaClientOptions
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.kafka.client.common.KafkaClientOptions
super_class: java.lang.Object
{
public static final java.lang.String DEFAULT_TRACE_PEER_ADDRESS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final io.vertx.core.tracing.TracingPolicy DEFAULT_TRACING_POLICY;
descriptor: Lio/vertx/core/tracing/TracingPolicy;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private java.util.Map<java.lang.String, java.lang.Object> config;
descriptor: Ljava/util/Map;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
private java.lang.String tracePeerAddress;
descriptor: Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.tracing.TracingPolicy tracingPolicy;
descriptor: Lio/vertx/core/tracing/TracingPolicy;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: aconst_null
putstatic io.vertx.kafka.client.common.KafkaClientOptions.DEFAULT_TRACE_PEER_ADDRESS:Ljava/lang/String;
1: getstatic io.vertx.core.tracing.TracingPolicy.PROPAGATE:Lio/vertx/core/tracing/TracingPolicy;
putstatic io.vertx.kafka.client.common.KafkaClientOptions.DEFAULT_TRACING_POLICY:Lio/vertx/core/tracing/TracingPolicy;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
getstatic io.vertx.kafka.client.common.KafkaClientOptions.DEFAULT_TRACE_PEER_ADDRESS:Ljava/lang/String;
putfield io.vertx.kafka.client.common.KafkaClientOptions.tracePeerAddress:Ljava/lang/String;
2: aload 0
getstatic io.vertx.kafka.client.common.KafkaClientOptions.DEFAULT_TRACING_POLICY:Lio/vertx/core/tracing/TracingPolicy;
putfield io.vertx.kafka.client.common.KafkaClientOptions.tracingPolicy:Lio/vertx/core/tracing/TracingPolicy;
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
public void <init>(io.vertx.core.json.JsonObject);
descriptor: (Lio/vertx/core/json/JsonObject;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial io.vertx.kafka.client.common.KafkaClientOptions.<init>:()V
1: aload 1
aload 0
invokestatic io.vertx.kafka.client.common.KafkaClientOptionsConverter.fromJson:(Ljava/lang/Iterable;Lio/vertx/kafka/client/common/KafkaClientOptions;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
0 3 1 json Lio/vertx/core/json/JsonObject;
MethodParameters:
Name Flags
json
public static io.vertx.kafka.client.common.KafkaClientOptions fromMap(java.util.Map<java.lang.String, java.lang.Object>, boolean);
descriptor: (Ljava/util/Map;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
iload 1
ifeq 1
ldc "bootstrap.servers"
goto 2
StackMap locals:
StackMap stack: java.util.Map
1: ldc "bootstrap.servers"
StackMap locals: java.util.Map int
StackMap stack: java.util.Map java.lang.String
2: ldc ""
invokeinterface java.util.Map.getOrDefault:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 2
start local 2 3: new io.vertx.kafka.client.common.KafkaClientOptions
dup
invokespecial io.vertx.kafka.client.common.KafkaClientOptions.<init>:()V
aload 2
invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.setTracePeerAddress:(Ljava/lang/String;)Lio/vertx/kafka/client/common/KafkaClientOptions;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
0 4 1 isProducer Z
3 4 2 tracePeerAddress Ljava/lang/String;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
MethodParameters:
Name Flags
config
isProducer
public static io.vertx.kafka.client.common.KafkaClientOptions fromProperties(java.util.Properties, boolean);
descriptor: (Ljava/util/Properties;Z)Lio/vertx/kafka/client/common/KafkaClientOptions;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
iload 1
ifeq 1
ldc "bootstrap.servers"
goto 2
StackMap locals:
StackMap stack: java.util.Properties
1: ldc "bootstrap.servers"
StackMap locals: java.util.Properties int
StackMap stack: java.util.Properties java.lang.String
2: ldc ""
invokevirtual java.util.Properties.getOrDefault:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 2
start local 2 3: new io.vertx.kafka.client.common.KafkaClientOptions
dup
invokespecial io.vertx.kafka.client.common.KafkaClientOptions.<init>:()V
aload 2
invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.setTracePeerAddress:(Ljava/lang/String;)Lio/vertx/kafka/client/common/KafkaClientOptions;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 config Ljava/util/Properties;
0 4 1 isProducer Z
3 4 2 tracePeerAddress Ljava/lang/String;
MethodParameters:
Name Flags
config
isProducer
public java.util.Map<java.lang.String, java.lang.Object> getConfig();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.common.KafkaClientOptions.config:Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
public io.vertx.kafka.client.common.KafkaClientOptions setConfig(java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (Ljava/util/Map;)Lio/vertx/kafka/client/common/KafkaClientOptions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.kafka.client.common.KafkaClientOptions.config:Ljava/util/Map;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
0 2 1 config Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Lio/vertx/kafka/client/common/KafkaClientOptions;
MethodParameters:
Name Flags
config
public io.vertx.kafka.client.common.KafkaClientOptions setConfig(java.lang.String, java.lang.Object);
descriptor: (Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/kafka/client/common/KafkaClientOptions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.kafka.client.common.KafkaClientOptions.config:Ljava/util/Map;
ifnonnull 2
1: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield io.vertx.kafka.client.common.KafkaClientOptions.config:Ljava/util/Map;
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.kafka.client.common.KafkaClientOptions.config:Ljava/util/Map;
aload 1
aload 2
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
0 4 1 key Ljava/lang/String;
0 4 2 value Ljava/lang/Object;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.GenIgnore()
RuntimeVisibleTypeAnnotations:
METHOD_RETURN
io.vertx.codegen.annotations.GenIgnore()
MethodParameters:
Name Flags
key
value
public io.vertx.core.tracing.TracingPolicy getTracingPolicy();
descriptor: ()Lio/vertx/core/tracing/TracingPolicy;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.common.KafkaClientOptions.tracingPolicy:Lio/vertx/core/tracing/TracingPolicy;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
public io.vertx.kafka.client.common.KafkaClientOptions setTracingPolicy(io.vertx.core.tracing.TracingPolicy);
descriptor: (Lio/vertx/core/tracing/TracingPolicy;)Lio/vertx/kafka/client/common/KafkaClientOptions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.kafka.client.common.KafkaClientOptions.tracingPolicy:Lio/vertx/core/tracing/TracingPolicy;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
0 2 1 tracingPolicy Lio/vertx/core/tracing/TracingPolicy;
MethodParameters:
Name Flags
tracingPolicy
public java.lang.String getTracePeerAddress();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.kafka.client.common.KafkaClientOptions.tracePeerAddress:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
public io.vertx.kafka.client.common.KafkaClientOptions setTracePeerAddress(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/kafka/client/common/KafkaClientOptions;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.kafka.client.common.KafkaClientOptions.tracePeerAddress:Ljava/lang/String;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
0 2 1 tracePeerAddress Ljava/lang/String;
MethodParameters:
Name Flags
tracePeerAddress
public io.vertx.core.json.JsonObject toJson();
descriptor: ()Lio/vertx/core/json/JsonObject;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: new io.vertx.core.json.JsonObject
dup
invokespecial io.vertx.core.json.JsonObject.<init>:()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/kafka/client/common/KafkaClientOptions;
}
SourceFile: "KafkaClientOptions.java"
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.DataObject(generateConverter = true)