public class io.vertx.kafka.client.common.tracing.ProducerTracer<S>
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.kafka.client.common.tracing.ProducerTracer
  super_class: java.lang.Object
{
  private final io.vertx.core.spi.tracing.VertxTracer<java.lang.Void, S> tracer;
    descriptor: Lio/vertx/core/spi/tracing/VertxTracer;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lio/vertx/core/spi/tracing/VertxTracer<Ljava/lang/Void;TS;>;

  private final java.lang.String address;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.lang.String hostname;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.lang.String port;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.core.tracing.TracingPolicy policy;
    descriptor: Lio/vertx/core/tracing/TracingPolicy;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  public static <S> io.vertx.kafka.client.common.tracing.ProducerTracer create(io.vertx.core.spi.tracing.VertxTracer, io.vertx.kafka.client.common.KafkaClientOptions);
    descriptor: (Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/common/tracing/ProducerTracer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // io.vertx.core.spi.tracing.VertxTracer tracer
        start local 1 // io.vertx.kafka.client.common.KafkaClientOptions opts
         0: .line 48
            aload 1 /* opts */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getTracingPolicy:()Lio/vertx/core/tracing/TracingPolicy;
            ifnull 1
            aload 1 /* opts */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getTracingPolicy:()Lio/vertx/core/tracing/TracingPolicy;
            goto 2
      StackMap locals:
      StackMap stack:
         1: getstatic io.vertx.core.tracing.TracingPolicy.PROPAGATE:Lio/vertx/core/tracing/TracingPolicy;
      StackMap locals:
      StackMap stack: io.vertx.core.tracing.TracingPolicy
         2: astore 2 /* policy */
        start local 2 // io.vertx.core.tracing.TracingPolicy policy
         3: .line 49
            aload 2 /* policy */
            getstatic io.vertx.core.tracing.TracingPolicy.IGNORE:Lio/vertx/core/tracing/TracingPolicy;
            if_acmpeq 4
            aload 0 /* tracer */
            ifnonnull 5
         4: .line 51
      StackMap locals: io.vertx.core.tracing.TracingPolicy
      StackMap stack:
            aconst_null
            areturn
         5: .line 53
      StackMap locals:
      StackMap stack:
            aload 1 /* opts */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getTracePeerAddress:()Ljava/lang/String;
            astore 3 /* address */
        start local 3 // java.lang.String address
         6: .line 55
            aload 3 /* address */
            ifnonnull 11
         7: .line 56
            aload 1 /* opts */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getConfig:()Ljava/util/Map;
            ifnull 10
         8: .line 57
            aload 1 /* opts */
            invokevirtual io.vertx.kafka.client.common.KafkaClientOptions.getConfig:()Ljava/util/Map;
            ldc "bootstrap.servers"
            ldc ""
            invokeinterface java.util.Map.getOrDefault:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.String
            astore 3 /* address */
         9: .line 58
            goto 11
        10: .line 59
      StackMap locals: java.lang.String
      StackMap stack:
            ldc ""
            astore 3 /* address */
        11: .line 62
      StackMap locals:
      StackMap stack:
            new io.vertx.kafka.client.common.tracing.ProducerTracer
            dup
            aload 0 /* tracer */
            aload 2 /* policy */
            aload 3 /* address */
            invokespecial io.vertx.kafka.client.common.tracing.ProducerTracer.<init>:(Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/core/tracing/TracingPolicy;Ljava/lang/String;)V
            areturn
        end local 3 // java.lang.String address
        end local 2 // io.vertx.core.tracing.TracingPolicy policy
        end local 1 // io.vertx.kafka.client.common.KafkaClientOptions opts
        end local 0 // io.vertx.core.spi.tracing.VertxTracer tracer
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   12     0   tracer  Lio/vertx/core/spi/tracing/VertxTracer;
            0   12     1     opts  Lio/vertx/kafka/client/common/KafkaClientOptions;
            3   12     2   policy  Lio/vertx/core/tracing/TracingPolicy;
            6   12     3  address  Ljava/lang/String;
    Signature: <S:Ljava/lang/Object;>(Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/kafka/client/common/KafkaClientOptions;)Lio/vertx/kafka/client/common/tracing/ProducerTracer;
    MethodParameters:
        Name  Flags
      tracer  
      opts    

  private void <init>(io.vertx.core.spi.tracing.VertxTracer<java.lang.Void, S>, io.vertx.core.tracing.TracingPolicy, java.lang.String);
    descriptor: (Lio/vertx/core/spi/tracing/VertxTracer;Lio/vertx/core/tracing/TracingPolicy;Ljava/lang/String;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=4
        start local 0 // io.vertx.kafka.client.common.tracing.ProducerTracer this
        start local 1 // io.vertx.core.spi.tracing.VertxTracer tracer
        start local 2 // io.vertx.core.tracing.TracingPolicy policy
        start local 3 // java.lang.String bootstrapServer
         0: .line 65
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 66
            aload 0 /* this */
            aload 1 /* tracer */
            putfield io.vertx.kafka.client.common.tracing.ProducerTracer.tracer:Lio/vertx/core/spi/tracing/VertxTracer;
         2: .line 67
            aload 0 /* this */
            aload 3 /* bootstrapServer */
            putfield io.vertx.kafka.client.common.tracing.ProducerTracer.address:Ljava/lang/String;
         3: .line 68
            aload 0 /* this */
            aload 3 /* bootstrapServer */
            invokestatic org.apache.kafka.common.utils.Utils.getHost:(Ljava/lang/String;)Ljava/lang/String;
            putfield io.vertx.kafka.client.common.tracing.ProducerTracer.hostname:Ljava/lang/String;
         4: .line 69
            aload 3 /* bootstrapServer */
            invokestatic org.apache.kafka.common.utils.Utils.getPort:(Ljava/lang/String;)Ljava/lang/Integer;
            astore 4 /* port */
        start local 4 // java.lang.Integer port
         5: .line 70
            aload 0 /* this */
            aload 4 /* port */
            ifnonnull 6
            aconst_null
            goto 7
      StackMap locals: io.vertx.kafka.client.common.tracing.ProducerTracer io.vertx.core.spi.tracing.VertxTracer io.vertx.core.tracing.TracingPolicy java.lang.String java.lang.Integer
      StackMap stack: io.vertx.kafka.client.common.tracing.ProducerTracer
         6: aload 4 /* port */
            invokevirtual java.lang.Integer.toString:()Ljava/lang/String;
      StackMap locals: io.vertx.kafka.client.common.tracing.ProducerTracer io.vertx.core.spi.tracing.VertxTracer io.vertx.core.tracing.TracingPolicy java.lang.String java.lang.Integer
      StackMap stack: io.vertx.kafka.client.common.tracing.ProducerTracer java.lang.String
         7: putfield io.vertx.kafka.client.common.tracing.ProducerTracer.port:Ljava/lang/String;
         8: .line 71
            aload 0 /* this */
            aload 2 /* policy */
            putfield io.vertx.kafka.client.common.tracing.ProducerTracer.policy:Lio/vertx/core/tracing/TracingPolicy;
         9: .line 72
            return
        end local 4 // java.lang.Integer port
        end local 3 // java.lang.String bootstrapServer
        end local 2 // io.vertx.core.tracing.TracingPolicy policy
        end local 1 // io.vertx.core.spi.tracing.VertxTracer tracer
        end local 0 // io.vertx.kafka.client.common.tracing.ProducerTracer this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lio/vertx/kafka/client/common/tracing/ProducerTracer<TS;>;
            0   10     1           tracer  Lio/vertx/core/spi/tracing/VertxTracer<Ljava/lang/Void;TS;>;
            0   10     2           policy  Lio/vertx/core/tracing/TracingPolicy;
            0   10     3  bootstrapServer  Ljava/lang/String;
            5   10     4             port  Ljava/lang/Integer;
    Signature: (Lio/vertx/core/spi/tracing/VertxTracer<Ljava/lang/Void;TS;>;Lio/vertx/core/tracing/TracingPolicy;Ljava/lang/String;)V
    MethodParameters:
                 Name  Flags
      tracer           
      policy           
      bootstrapServer  

  public io.vertx.kafka.client.common.tracing.ProducerTracer<S>.StartedSpan prepareSendMessage(io.vertx.core.Context, org.apache.kafka.clients.producer.ProducerRecord);
    descriptor: (Lio/vertx/core/Context;Lorg/apache/kafka/clients/producer/ProducerRecord;)Lio/vertx/kafka/client/common/tracing/ProducerTracer$StartedSpan;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=8, locals=5, args_size=3
        start local 0 // io.vertx.kafka.client.common.tracing.ProducerTracer this
        start local 1 // io.vertx.core.Context context
        start local 2 // org.apache.kafka.clients.producer.ProducerRecord record
         0: .line 75
            new io.vertx.kafka.client.common.tracing.TraceContext
            dup
            ldc "producer"
            aload 0 /* this */
            getfield io.vertx.kafka.client.common.tracing.ProducerTracer.address:Ljava/lang/String;
            aload 0 /* this */
            getfield io.vertx.kafka.client.common.tracing.ProducerTracer.hostname:Ljava/lang/String;
            aload 0 /* this */
            getfield io.vertx.kafka.client.common.tracing.ProducerTracer.port:Ljava/lang/String;
            aload 2 /* record */
            invokevirtual org.apache.kafka.clients.producer.ProducerRecord.topic:()Ljava/lang/String;
            invokespecial io.vertx.kafka.client.common.tracing.TraceContext.<init>:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
            astore 3 /* tc */
        start local 3 // io.vertx.kafka.client.common.tracing.TraceContext tc
         1: .line 76
            aload 0 /* this */
            getfield io.vertx.kafka.client.common.tracing.ProducerTracer.tracer:Lio/vertx/core/spi/tracing/VertxTracer;
            aload 1 /* context */
            getstatic io.vertx.core.spi.tracing.SpanKind.MESSAGING:Lio/vertx/core/spi/tracing/SpanKind;
            aload 0 /* this */
            getfield io.vertx.kafka.client.common.tracing.ProducerTracer.policy:Lio/vertx/core/tracing/TracingPolicy;
            aload 3 /* tc */
            ldc "kafka_send"
            aload 2 /* record */
            invokedynamic accept(Lorg/apache/kafka/clients/producer/ProducerRecord;)Ljava/util/function/BiConsumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)V
                  io/vertx/kafka/client/common/tracing/ProducerTracer.lambda$0(Lorg/apache/kafka/clients/producer/ProducerRecord;Ljava/lang/String;Ljava/lang/String;)V (6)
                  (Ljava/lang/String;Ljava/lang/String;)V
            getstatic io.vertx.kafka.client.common.tracing.TraceTags.TAG_EXTRACTOR:Lio/vertx/core/spi/tracing/TagExtractor;
            invokeinterface io.vertx.core.spi.tracing.VertxTracer.sendRequest:(Lio/vertx/core/Context;Lio/vertx/core/spi/tracing/SpanKind;Lio/vertx/core/tracing/TracingPolicy;Ljava/lang/Object;Ljava/lang/String;Ljava/util/function/BiConsumer;Lio/vertx/core/spi/tracing/TagExtractor;)Ljava/lang/Object;
            astore 4 /* span */
        start local 4 // java.lang.Object span
         2: .line 77
            new io.vertx.kafka.client.common.tracing.ProducerTracer$StartedSpan
            dup
            aload 0 /* this */
            aload 4 /* span */
            invokespecial io.vertx.kafka.client.common.tracing.ProducerTracer$StartedSpan.<init>:(Lio/vertx/kafka/client/common/tracing/ProducerTracer;Ljava/lang/Object;)V
            areturn
        end local 4 // java.lang.Object span
        end local 3 // io.vertx.kafka.client.common.tracing.TraceContext tc
        end local 2 // org.apache.kafka.clients.producer.ProducerRecord record
        end local 1 // io.vertx.core.Context context
        end local 0 // io.vertx.kafka.client.common.tracing.ProducerTracer this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/kafka/client/common/tracing/ProducerTracer<TS;>;
            0    3     1  context  Lio/vertx/core/Context;
            0    3     2   record  Lorg/apache/kafka/clients/producer/ProducerRecord;
            1    3     3       tc  Lio/vertx/kafka/client/common/tracing/TraceContext;
            2    3     4     span  TS;
    Signature: (Lio/vertx/core/Context;Lorg/apache/kafka/clients/producer/ProducerRecord;)Lio/vertx/kafka/client/common/tracing/ProducerTracer<TS;>.StartedSpan;
    MethodParameters:
         Name  Flags
      context  
      record   

  private static void lambda$0(org.apache.kafka.clients.producer.ProducerRecord, java.lang.String, java.lang.String);
    descriptor: (Lorg/apache/kafka/clients/producer/ProducerRecord;Ljava/lang/String;Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 1 // java.lang.String k
        start local 2 // java.lang.String v
         0: .line 76
            aload 0
            invokevirtual org.apache.kafka.clients.producer.ProducerRecord.headers:()Lorg/apache/kafka/common/header/Headers;
            aload 1 /* k */
            aload 2 /* v */
            invokevirtual java.lang.String.getBytes:()[B
            invokeinterface org.apache.kafka.common.header.Headers.add:(Ljava/lang/String;[B)Lorg/apache/kafka/common/header/Headers;
            return
        end local 2 // java.lang.String v
        end local 1 // java.lang.String k
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1     k  Ljava/lang/String;
            0    1     2     v  Ljava/lang/String;
}
Signature: <S:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "ProducerTracer.java"
NestMembers:
  io.vertx.kafka.client.common.tracing.ProducerTracer$StartedSpan
InnerClasses:
  public StartedSpan = io.vertx.kafka.client.common.tracing.ProducerTracer$StartedSpan of io.vertx.kafka.client.common.tracing.ProducerTracer
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles