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 <saul.gill@est.tech>

1 files changed, 3 insertions, 0 deletions

diff --git a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineDmaapTopicSink.java b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineDmaapTopicSink.java
index a7a692de..771efb33 100644
--- a/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineDmaapTopicSink.java
+++ b/policy-endpoints/src/main/java/org/onap/policy/common/endpoints/event/comm/bus/internal/InlineDmaapTopicSink.java
@@ -59,6 +59,7 @@ public class InlineDmaapTopicSink extends InlineBusTopicSink implements DmaapTop
      * longitude            DME2 Longitude
      * additionalProps      Additional properties to pass to DME2
      * useHttps             does connection use HTTPS?
+     * allowTracing         is tracing allowed?
      * allowSelfSignedCerts are self-signed certificates allow
      * @param busTopicParams Contains the above mentioned parameters
      * @throws IllegalArgumentException An invalid parameter passed in
@@ -92,6 +93,7 @@ public class InlineDmaapTopicSink extends InlineBusTopicSink implements DmaapTop
                     .userName(this.userName)
                     .password(this.password)
                     .useHttps(this.useHttps)
+                    .allowTracing(this.allowTracing)
                     .allowSelfSignedCerts(this.allowSelfSignedCerts)
                     .build());
         } else {
@@ -107,6 +109,7 @@ public class InlineDmaapTopicSink extends InlineBusTopicSink implements DmaapTop
                     .longitude(this.longitude)
                     .additionalProps(this.additionalProps)
                     .useHttps(this.useHttps)
+                    .allowTracing(this.allowTracing)
                     .build());
         }