X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=influxlogger%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmlog%2FKafkaTopicListener.java;h=1617f1dec7fa94ac4a13a053b84df2f105ba704e;hb=7e81fc8f80de769772fd41d762706f66519f13e2;hp=390ccaee0aa65a00229d8d13d3e2bec24efe93e5;hpb=9e3ded97088f197b335d060e1c9ddf7d6c0ecd89;p=nonrtric%2Fplt%2Franpm.git

diff --git a/influxlogger/src/main/java/org/oran/pmlog/KafkaTopicListener.java b/influxlogger/src/main/java/org/oran/pmlog/KafkaTopicListener.java
index 390ccae..1617f1d 100644
--- a/influxlogger/src/main/java/org/oran/pmlog/KafkaTopicListener.java
+++ b/influxlogger/src/main/java/org/oran/pmlog/KafkaTopicListener.java
@@ -89,6 +89,7 @@ public class KafkaTopicListener {
         consumerProps.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false);
 
         consumerProps.put(ConsumerConfig.CLIENT_ID_CONFIG, clientId + "_" + applicationConfig.getKafkaGroupId());
+        this.applicationConfig.addKafkaSecurityProps(consumerProps);
 
         return ReceiverOptions.<byte[], byte[]>create(consumerProps)
                 .subscription(Collections.singleton(this.applicationConfig.getKafkaInputTopic()));