From 0241c0aa14447c99fccecc61e91b35051d6743be Mon Sep 17 00:00:00 2001 From: "saul.gill" Date: Mon, 22 Jan 2024 11:59:07 +0000 Subject: Addition of tracing for Kafka Added open telemetry-based interceptors Messages will be tagged with tracing information Issue-ID: POLICY-4922 Change-Id: If4234a642c3eb7dd6c3acaf2f06b2efb2ddef8af Signed-off-by: saul.gill --- .../event/comm/bus/internal/SingleThreadedDmaapTopicSource.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedDmaapTopicSource.java') diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedDmaapTopicSource.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedDmaapTopicSource.java index 09ce5261..26960379 100644 --- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedDmaapTopicSource.java +++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/SingleThreadedDmaapTopicSource.java @@ -93,7 +93,8 @@ public class SingleThreadedDmaapTopicSource extends SingleThreadedBusTopicSource .consumerInstance(this.consumerInstance) .fetchTimeout(this.fetchTimeout) .fetchLimit(this.fetchLimit) - .useHttps(this.useHttps); + .useHttps(this.useHttps) + .allowTracing(this.allowTracing); if (anyNullOrEmpty(this.userName, this.password)) { this.consumer = new BusConsumer.CambriaConsumerWrapper(builder -- cgit 1.2.3-korg