move logging to topicService

FINTLabs · Dec 16, 2024 · 2cfbd04 · 2cfbd04
1 parent 34d3fcb
commit 2cfbd04
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/main/java/no/fintlabs/provider/datasync/EntityProducerKafka.java b/src/main/java/no/fintlabs/provider/datasync/EntityProducerKafka.java
@@ -55,8 +55,6 @@ private void attachRetensionTimeToHeader(RecordHeaders headers, EntityTopicNameP
             ByteBuffer buffer = ByteBuffer.allocate(Long.BYTES);
             buffer.putLong(retensionTime);
             headers.add(HEADER_RETENSION_TIME, buffer.array());
-        } else {
-            log.error("Retension time was not fetched for entityTopicName: {}", entityTopicName.getTopicName());
         }
     }
 }
diff --git a/src/main/java/no/fintlabs/provider/kafka/ProviderTopicService.java b/src/main/java/no/fintlabs/provider/kafka/ProviderTopicService.java
@@ -22,7 +22,12 @@ public class ProviderTopicService {
     private final EventTopicService eventTopicService;
 
     public long getRetensionTime(TopicNameParameters topicNameParameters) {
-        return topicToRetensionMap.getOrDefault(topicNameParameters.getTopicName(), 0L);
+        if (topicToRetensionMap.containsKey(topicNameParameters.getTopicName())) {
+            return topicToRetensionMap.get(topicNameParameters.getTopicName());
+        } else {
+            log.error("Cant get retension time because topic is not ensured: {}", topicNameParameters.getTopicName());
+            return 0L;
+        }
     }
 
     public boolean topicHasDifferentRetensionTime(TopicNameParameters topicNameParameters, Long retensionTime) {