Class ConsumerTracer<S>
- java.lang.Object
- 
- io.vertx.kafka.client.common.tracing.ConsumerTracer<S>
 
- 
 public class ConsumerTracer<S> extends Object Tracer for Kafka consumer, wrapping the generic tracer.
- 
- 
Nested Class SummaryNested Classes Modifier and Type Class Description classConsumerTracer.StartedSpan
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <S> ConsumerTracercreate(VertxTracer tracer, KafkaClientOptions opts)Creates a ConsumerTracer, which provides an opinionated facade for usingVertxTracerwith a Kafka Consumer use case.ConsumerTracer.StartedSpanprepareMessageReceived(Context context, org.apache.kafka.clients.consumer.ConsumerRecord rec)
 
- 
- 
- 
Method Detail- 
createpublic static <S> ConsumerTracer create(VertxTracer tracer, KafkaClientOptions opts) Creates a ConsumerTracer, which provides an opinionated facade for usingVertxTracerwith a Kafka Consumer use case. The method will returnnullif Tracing is not setup in Vert.x, or ifTracingPolicy.IGNOREis used.- Type Parameters:
- S- the type of spans that is going to be generated, depending on the tracing system (zipkin, opentracing ...)
- Parameters:
- tracer- the generic tracer object
- opts- Kafka client options
- Returns:
- a new instance of ConsumerTracer, ornull
 
 - 
prepareMessageReceivedpublic ConsumerTracer.StartedSpan prepareMessageReceived(Context context, org.apache.kafka.clients.consumer.ConsumerRecord rec) 
 
- 
 
-