From e159560bcae11b1ae7c8c20033e0f8b553261435 Mon Sep 17 00:00:00 2001
From: Brage <brage.skjonborg@hotmail.no>
Date: Thu, 14 Mar 2024 23:29:19 +0100
Subject: [PATCH] Filter

---
 .../kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
index 0645d190..08bf2eed 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Coordinator.kt
@@ -48,6 +48,10 @@ class Coordinator(): CoordinatorBase<PersistentProcessDataMessage, PersistentEve
     }
 
     override fun onMessageReceived(event: DeserializedConsumerRecord<KafkaEvents, Message<out MessageDataWrapper>>) {
+        if (!processKafkaEvents.contains(event.key)) {
+            return
+        }
+
         val success = PersistentDataStore().storeProcessDataMessage(event.key.event, event.value)
         if (!success) {
             log.error { "Unable to store message: ${event.key.event} in database ${DatabaseConfig.database}" }