public class ConsumerTracer<S> extends Object
Modifier and Type | Class and Description |
---|---|
class |
ConsumerTracer.StartedSpan |
Modifier and Type | Method and Description |
---|---|
static <S> ConsumerTracer |
create(VertxTracer tracer,
KafkaClientOptions opts)
Creates a ConsumerTracer, which provides an opinionated facade for using
VertxTracer
with a Kafka Consumer use case. |
ConsumerTracer.StartedSpan |
prepareMessageReceived(Context context,
org.apache.kafka.clients.consumer.ConsumerRecord rec) |
public static <S> ConsumerTracer create(VertxTracer tracer, KafkaClientOptions opts)
VertxTracer
with a Kafka Consumer use case.
The method will return null
if Tracing is not setup in Vert.x, or if TracingPolicy.IGNORE
is used.S
- the type of spans that is going to be generated, depending on the tracing system (zipkin, opentracing ...)tracer
- the generic tracer objectopts
- Kafka client optionsConsumerTracer
, or null
public ConsumerTracer.StartedSpan prepareMessageReceived(Context context, org.apache.kafka.clients.consumer.ConsumerRecord rec)
Copyright © 2023 Eclipse. All rights reserved.