Skip to content

Commit dfc8b4a

Browse files
committed
Use unwrapped verxInternal's tracer()
Signed-off-by: Matthias Wessendorf <[email protected]>
1 parent 95b7834 commit dfc8b4a

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

data-plane/receiver-loom/src/main/java/dev/knative/eventing/kafka/broker/receiverloom/LoomKafkaProducer.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,8 @@ public LoomKafkaProducer(Vertx v, Producer<K, V> producer) {
5757
final var ctxInt = ((ContextInternal) v.getOrCreateContext()).unwrap();
5858
if (ctxInt.tracer() != null) {
5959
this.tracer =
60-
new ProducerTracer(ctxInt.tracer(), TracingPolicy.PROPAGATE, "" /* TODO add bootrstrap servers */);
60+
new ProducerTracer(this.vertx.tracer(), TracingPolicy.PROPAGATE, "" /* TODO add bootrstrap servers */);
61+
// new ProducerTracer(ctxInt.tracer(), TracingPolicy.PROPAGATE, "" /* TODO add bootrstrap servers */);
6162
} else {
6263
this.tracer = null;
6364
}

0 commit comments

Comments
 (0)