Adding source name to kafka headers

[nonrtric/plt/ranpm.git] / pmproducer / src / main / java / org / oran / pmproducer / repository / Job.java

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 (file)
--- 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);
     }
 }