X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pmproducer%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmproducer%2Frepository%2FJob.java;h=7f1e4a1d56e90a63c1a45f8cad2a2bb9d3042f13;hb=b93342e4652c65929e23f775f4e64773cf3323e4;hp=e3c0e8a27f21c878904317361aa5ddbdf1514bdb;hpb=d806dbef4f43bb9c631c818e96c1a39e440c5e6c;p=nonrtric%2Fplt%2Franpm.git

diff --git a/pmproducer/src/main/java/org/oran/pmproducer/repository/Job.java b/pmproducer/src/main/java/org/oran/pmproducer/repository/Job.java
index e3c0e8a..7f1e4a1 100644
--- a/pmproducer/src/main/java/org/oran/pmproducer/repository/Job.java
+++ b/pmproducer/src/main/java/org/oran/pmproducer/repository/Job.java
@@ -153,14 +153,9 @@ public class Job {
                 .typeId(type.getId()) //
                 .clientId(type.getKafkaClientId(appConfig)) //
                 .build();
-
     }
 
     public FilteredData filter(DataFromTopic data) {
-        if (filter == null) {
-            logger.debug("No filter used");
-            return new FilteredData(data.infoTypeId, data.key, data.value);
-        }
         return filter.filter(data);
     }
 }